#-------------------------------------------------- # There are 1 DAGs in the session #-------------------------------------------------- #-------------------------------------------------- # TEZ DAG plan: scope-121 #-------------------------------------------------- Tez vertex scope-109 -> Tez vertex scope-110, Tez vertex scope-103 -> Tez vertex scope-110, Tez vertex scope-110 Tez vertex scope-109 # Plan on vertex POValueOutputTez - scope-113 -> [scope-110] | |---c: New For Each(false,false)[bag] - scope-89 | | | Cast[int] - scope-84 | | | |---Project[bytearray][1] - scope-83 | | | Cast[chararray] - scope-87 | | | |---Project[bytearray][0] - scope-86 | |---b: Load(file:///tmp/input:org.apache.pig.builtin.PigStorage) - scope-82 Tez vertex scope-103 # Plan on vertex 1-12: Split - scope-120 | | | a2: Store(file:///tmp/output/a2:org.apache.pig.builtin.PigStorage) - scope-77 | | | |---a2: Filter[bag] - scope-72 | | | | | Not[boolean] - scope-76 | | | | | |---Greater Than[boolean] - scope-75 | | | | | |---Project[int][0] - scope-73 | | | | | |---Constant(100) - scope-74 | | | POValueOutputTez - scope-112 -> [scope-110] | | | |---a1: Filter[bag] - scope-78 | | | | | Greater Than[boolean] - scope-81 | | | | | |---Project[int][0] - scope-79 | | | | | |---Constant(100) - scope-80 | |---a: New For Each(false,false)[bag] - scope-70 | | | Cast[int] - scope-65 | | | |---Project[bytearray][0] - scope-64 | | | Cast[chararray] - scope-68 | | | |---Project[bytearray][1] - scope-67 | |---a: Load(file:///tmp/input:org.apache.pig.builtin.PigStorage) - scope-63 Tez vertex scope-110 # Plan on vertex 1-13: Split - scope-119 | | | d: Store(file:///tmp/output/d:org.apache.pig.builtin.PigStorage) - scope-96 | | | |---d: Filter[bag] - scope-92 | | | | | Greater Than[boolean] - scope-95 | | | | | |---Project[int][0] - scope-93 | | | | | |---Constant(500) - scope-94 | | | e: Store(file:///tmp/output/e:org.apache.pig.builtin.PigStorage) - scope-102 | | | |---e: Filter[bag] - scope-97 | | | | | Not[boolean] - scope-101 | | | | | |---Greater Than[boolean] - scope-100 | | | | | |---Project[int][0] - scope-98 | | | | | |---Constant(500) - scope-99 | |---POShuffledValueInputTez - scope-111 <- [scope-109, scope-103]