Modified: pig/branches/spark/test/org/apache/pig/test/data/GoldenFiles/tez/TEZC-MQ-4-OPTOFF.gld URL: http://svn.apache.org/viewvc/pig/branches/spark/test/org/apache/pig/test/data/GoldenFiles/tez/TEZC-MQ-4-OPTOFF.gld?rev=1642132&r1=1642131&r2=1642132&view=diff ============================================================================== --- pig/branches/spark/test/org/apache/pig/test/data/GoldenFiles/tez/TEZC-MQ-4-OPTOFF.gld (original) +++ pig/branches/spark/test/org/apache/pig/test/data/GoldenFiles/tez/TEZC-MQ-4-OPTOFF.gld Thu Nov 27 12:49:54 2014 @@ -2,90 +2,90 @@ # There are 1 DAGs in the session #-------------------------------------------------- #-------------------------------------------------- -# TEZ DAG plan: scope-128 +# TEZ DAG plan: pig-0_scope-1 #-------------------------------------------------- -Tez vertex scope-118 -> Tez vertex scope-120, -Tez vertex scope-119 -> Tez vertex scope-120, -Tez vertex scope-120 -> Tez vertex scope-122,Tez vertex scope-124,Tez vertex scope-126, -Tez vertex scope-122 -Tez vertex scope-124 -Tez vertex scope-126 +Tez vertex scope-117 -> Tez vertex scope-119, +Tez vertex scope-118 -> Tez vertex scope-119, +Tez vertex scope-119 -> Tez vertex scope-121,Tez vertex scope-123,Tez vertex scope-125, +Tez vertex scope-123 +Tez vertex scope-125 +Tez vertex scope-121 -Tez vertex scope-118 +Tez vertex scope-117 # Plan on vertex -c: Local Rearrange[tuple]{int}(false) - scope-85 -> scope-120 +c: Local Rearrange[tuple]{int}(false) - scope-84 -> scope-119 | | -| Project[int][0] - scope-86 +| Project[int][0] - scope-85 | -|---a: New For Each(false,false)[bag] - scope-72 +|---a: New For Each(false,false)[bag] - scope-71 | | - | Cast[int] - scope-67 + | Cast[int] - scope-66 | | - | |---Project[bytearray][0] - scope-66 + | |---Project[bytearray][0] - scope-65 | | - | Cast[int] - scope-70 + | Cast[int] - scope-69 | | - | |---Project[bytearray][1] - scope-69 + | |---Project[bytearray][1] - scope-68 | - |---a: Load(file:///tmp/input1:org.apache.pig.builtin.PigStorage) - scope-65 -Tez vertex scope-119 + |---a: Load(file:///tmp/input1:org.apache.pig.builtin.PigStorage) - scope-64 +Tez vertex scope-118 # Plan on vertex -c: Local Rearrange[tuple]{int}(false) - scope-87 -> scope-120 +c: Local Rearrange[tuple]{int}(false) - scope-86 -> scope-119 | | -| Project[int][0] - scope-88 +| Project[int][0] - scope-87 | -|---b: New For Each(false,false)[bag] - scope-80 +|---b: New For Each(false,false)[bag] - scope-79 | | - | Cast[int] - scope-75 + | Cast[int] - scope-74 | | - | |---Project[bytearray][0] - scope-74 + | |---Project[bytearray][0] - scope-73 | | - | Cast[int] - scope-78 + | Cast[int] - scope-77 | | - | |---Project[bytearray][1] - scope-77 + | |---Project[bytearray][1] - scope-76 | - |---b: Load(file:///tmp/input2:org.apache.pig.builtin.PigStorage) - scope-73 -Tez vertex scope-120 + |---b: Load(file:///tmp/input2:org.apache.pig.builtin.PigStorage) - scope-72 +Tez vertex scope-119 # Plan on vertex -POValueOutputTez - scope-121 -> [scope-122, scope-124, scope-126] +POValueOutputTez - scope-120 -> [scope-123, scope-125, scope-121] | -|---c: New For Each(true,true)[tuple] - scope-91 +|---c: New For Each(true,true)[tuple] - scope-90 | | - | Project[bag][1] - scope-89 + | Project[bag][1] - scope-88 | | - | Project[bag][2] - scope-90 + | Project[bag][2] - scope-89 | - |---c: Package(Packager)[tuple]{int} - scope-84 -Tez vertex scope-122 + |---c: Package(Packager)[tuple]{int} - scope-83 +Tez vertex scope-123 # Plan on vertex -c: Store(file:///tmp/output/c:org.apache.pig.builtin.PigStorage) - scope-95 +d: Store(file:///tmp/output/d:org.apache.pig.builtin.PigStorage) - scope-104 | -|---POValueInputTez - scope-123 <- scope-120 -Tez vertex scope-124 -# Plan on vertex -d: Store(file:///tmp/output/d:org.apache.pig.builtin.PigStorage) - scope-105 -| -|---d: New For Each(false,false,false)[bag] - scope-104 +|---d: New For Each(false,false,false)[bag] - scope-103 | | - | Project[int][0] - scope-98 + | Project[int][0] - scope-97 | | - | Project[int][1] - scope-100 + | Project[int][1] - scope-99 | | - | Project[int][3] - scope-102 + | Project[int][3] - scope-101 | - |---POValueInputTez - scope-125 <- scope-120 -Tez vertex scope-126 + |---POValueInputTez - scope-124 <- scope-119 +Tez vertex scope-125 # Plan on vertex -e: Store(file:///tmp/output/e:org.apache.pig.builtin.PigStorage) - scope-117 +e: Store(file:///tmp/output/e:org.apache.pig.builtin.PigStorage) - scope-116 | -|---e: New For Each(false,false,false,false)[bag] - scope-116 +|---e: New For Each(false,false,false,false)[bag] - scope-115 | | - | Project[int][0] - scope-108 + | Project[int][0] - scope-107 | | - | Project[int][1] - scope-110 + | Project[int][1] - scope-109 | | - | Project[int][2] - scope-112 + | Project[int][2] - scope-111 | | - | Project[int][3] - scope-114 + | Project[int][3] - scope-113 | - |---POValueInputTez - scope-127 <- scope-120 + |---POValueInputTez - scope-126 <- scope-119 +Tez vertex scope-121 +# Plan on vertex +c: Store(file:///tmp/output/c:org.apache.pig.builtin.PigStorage) - scope-94 +| +|---POValueInputTez - scope-122 <- scope-119
Modified: pig/branches/spark/test/org/apache/pig/test/data/GoldenFiles/tez/TEZC-MQ-4.gld URL: http://svn.apache.org/viewvc/pig/branches/spark/test/org/apache/pig/test/data/GoldenFiles/tez/TEZC-MQ-4.gld?rev=1642132&r1=1642131&r2=1642132&view=diff ============================================================================== --- pig/branches/spark/test/org/apache/pig/test/data/GoldenFiles/tez/TEZC-MQ-4.gld (original) +++ pig/branches/spark/test/org/apache/pig/test/data/GoldenFiles/tez/TEZC-MQ-4.gld Thu Nov 27 12:49:54 2014 @@ -2,7 +2,7 @@ # There are 1 DAGs in the session #-------------------------------------------------- #-------------------------------------------------- -# TEZ DAG plan: scope-63 +# TEZ DAG plan: pig-0_scope-0 #-------------------------------------------------- Tez vertex scope-53 -> Tez vertex scope-55, Tez vertex scope-54 -> Tez vertex scope-55, @@ -44,7 +44,7 @@ c: Local Rearrange[tuple]{int}(false) - |---b: Load(file:///tmp/input2:org.apache.pig.builtin.PigStorage) - scope-8 Tez vertex scope-55 # Plan on vertex -c: Split - scope-64 +c: Split - scope-63 | | | c: Store(file:///tmp/output/c:org.apache.pig.builtin.PigStorage) - scope-30 | | Modified: pig/branches/spark/test/org/apache/pig/test/data/GoldenFiles/tez/TEZC-MQ-5-OPTOFF.gld URL: http://svn.apache.org/viewvc/pig/branches/spark/test/org/apache/pig/test/data/GoldenFiles/tez/TEZC-MQ-5-OPTOFF.gld?rev=1642132&r1=1642131&r2=1642132&view=diff ============================================================================== --- pig/branches/spark/test/org/apache/pig/test/data/GoldenFiles/tez/TEZC-MQ-5-OPTOFF.gld (original) +++ pig/branches/spark/test/org/apache/pig/test/data/GoldenFiles/tez/TEZC-MQ-5-OPTOFF.gld Thu Nov 27 12:49:54 2014 @@ -2,80 +2,80 @@ # There are 1 DAGs in the session #-------------------------------------------------- #-------------------------------------------------- -# TEZ DAG plan: scope-117 +# TEZ DAG plan: pig-0_scope-1 #-------------------------------------------------- -Tez vertex scope-103 -> Tez vertex scope-104, -Tez vertex scope-104 -> Tez vertex scope-106,Tez vertex scope-108,Tez vertex scope-110, -Tez vertex scope-110 -> Tez vertex scope-113,Tez vertex scope-115, -Tez vertex scope-113 -Tez vertex scope-115 -Tez vertex scope-106 -Tez vertex scope-108 +Tez vertex scope-102 -> Tez vertex scope-103, +Tez vertex scope-103 -> Tez vertex scope-105,Tez vertex scope-107,Tez vertex scope-109, +Tez vertex scope-109 -> Tez vertex scope-112,Tez vertex scope-114, +Tez vertex scope-114 +Tez vertex scope-112 +Tez vertex scope-107 +Tez vertex scope-105 -Tez vertex scope-103 +Tez vertex scope-102 # Plan on vertex -b: Local Rearrange[tuple]{int}(false) - scope-70 -> scope-104 +b: Local Rearrange[tuple]{int}(false) - scope-69 -> scope-103 | | -| Project[int][0] - scope-71 +| Project[int][0] - scope-70 | -|---a: New For Each(false,false)[bag] - scope-67 +|---a: New For Each(false,false)[bag] - scope-66 | | - | Cast[int] - scope-62 + | Cast[int] - scope-61 | | - | |---Project[bytearray][0] - scope-61 + | |---Project[bytearray][0] - scope-60 | | - | Cast[int] - scope-65 + | Cast[int] - scope-64 | | - | |---Project[bytearray][1] - scope-64 + | |---Project[bytearray][1] - scope-63 | - |---a: Load(file:///tmp/input:org.apache.pig.builtin.PigStorage) - scope-60 -Tez vertex scope-104 + |---a: Load(file:///tmp/input:org.apache.pig.builtin.PigStorage) - scope-59 +Tez vertex scope-103 # Plan on vertex -POValueOutputTez - scope-105 -> [scope-106, scope-108, scope-110] +POValueOutputTez - scope-104 -> [scope-107, scope-109, scope-105] | -|---b: Package(Packager)[tuple]{int} - scope-69 -Tez vertex scope-110 +|---b: Package(Packager)[tuple]{int} - scope-68 +Tez vertex scope-109 # Plan on vertex -POValueOutputTez - scope-112 -> [scope-113, scope-115] +POValueOutputTez - scope-111 -> [scope-114, scope-112] | -|---d: New For Each(true)[bag] - scope-90 +|---d: New For Each(true)[bag] - scope-89 | | - | Project[bag][1] - scope-88 + | Project[bag][1] - scope-87 | - |---POValueInputTez - scope-111 <- scope-104 -Tez vertex scope-113 -# Plan on vertex -d: Store(file:///tmp/output/d:org.apache.pig.builtin.PigStorage) - scope-94 -| -|---POValueInputTez - scope-114 <- scope-110 -Tez vertex scope-115 + |---POValueInputTez - scope-110 <- scope-103 +Tez vertex scope-114 # Plan on vertex -e: Store(file:///tmp/output/e:org.apache.pig.builtin.PigStorage) - scope-102 +e: Store(file:///tmp/output/e:org.apache.pig.builtin.PigStorage) - scope-101 | -|---e: New For Each(false,false)[bag] - scope-101 +|---e: New For Each(false,false)[bag] - scope-100 | | - | Project[int][0] - scope-97 + | Project[int][0] - scope-96 | | - | Project[int][1] - scope-99 + | Project[int][1] - scope-98 | - |---POValueInputTez - scope-116 <- scope-110 -Tez vertex scope-106 + |---POValueInputTez - scope-115 <- scope-109 +Tez vertex scope-112 # Plan on vertex -b: Store(file:///tmp/output/b:org.apache.pig.builtin.PigStorage) - scope-75 +d: Store(file:///tmp/output/d:org.apache.pig.builtin.PigStorage) - scope-93 | -|---POValueInputTez - scope-107 <- scope-104 -Tez vertex scope-108 +|---POValueInputTez - scope-113 <- scope-109 +Tez vertex scope-107 # Plan on vertex -c: Store(file:///tmp/output/c:org.apache.pig.builtin.PigStorage) - scope-85 +c: Store(file:///tmp/output/c:org.apache.pig.builtin.PigStorage) - scope-84 | -|---c: New For Each(false,false)[bag] - scope-84 +|---c: New For Each(false,false)[bag] - scope-83 | | - | Project[bag][0] - scope-79 + | Project[bag][0] - scope-78 | | - | |---Project[bag][1] - scope-78 + | |---Project[bag][1] - scope-77 | | - | Project[bag][1] - scope-82 + | Project[bag][1] - scope-81 | | - | |---Project[bag][1] - scope-81 + | |---Project[bag][1] - scope-80 | - |---POValueInputTez - scope-109 <- scope-104 + |---POValueInputTez - scope-108 <- scope-103 +Tez vertex scope-105 +# Plan on vertex +b: Store(file:///tmp/output/b:org.apache.pig.builtin.PigStorage) - scope-74 +| +|---POValueInputTez - scope-106 <- scope-103 Modified: pig/branches/spark/test/org/apache/pig/test/data/GoldenFiles/tez/TEZC-MQ-5.gld URL: http://svn.apache.org/viewvc/pig/branches/spark/test/org/apache/pig/test/data/GoldenFiles/tez/TEZC-MQ-5.gld?rev=1642132&r1=1642131&r2=1642132&view=diff ============================================================================== --- pig/branches/spark/test/org/apache/pig/test/data/GoldenFiles/tez/TEZC-MQ-5.gld (original) +++ pig/branches/spark/test/org/apache/pig/test/data/GoldenFiles/tez/TEZC-MQ-5.gld Thu Nov 27 12:49:54 2014 @@ -2,7 +2,7 @@ # There are 1 DAGs in the session #-------------------------------------------------- #-------------------------------------------------- -# TEZ DAG plan: scope-57 +# TEZ DAG plan: pig-0_scope-0 #-------------------------------------------------- Tez vertex scope-43 -> Tez vertex scope-44, Tez vertex scope-44 @@ -26,7 +26,7 @@ b: Local Rearrange[tuple]{int}(false) - |---a: Load(file:///tmp/input:org.apache.pig.builtin.PigStorage) - scope-0 Tez vertex scope-44 # Plan on vertex -b: Split - scope-59 +b: Split - scope-58 | | | b: Store(file:///tmp/output/b:org.apache.pig.builtin.PigStorage) - scope-15 | | @@ -42,7 +42,7 @@ b: Split - scope-59 | | | | | |---Project[bag][1] - scope-21 | | -| d: Split - scope-58 +| d: Split - scope-57 | | | | | d: Store(file:///tmp/output/d:org.apache.pig.builtin.PigStorage) - scope-34 | | | Modified: pig/branches/spark/test/org/apache/pig/test/data/GoldenFiles/tez/TEZC-Rank-1.gld URL: http://svn.apache.org/viewvc/pig/branches/spark/test/org/apache/pig/test/data/GoldenFiles/tez/TEZC-Rank-1.gld?rev=1642132&r1=1642131&r2=1642132&view=diff ============================================================================== --- pig/branches/spark/test/org/apache/pig/test/data/GoldenFiles/tez/TEZC-Rank-1.gld (original) +++ pig/branches/spark/test/org/apache/pig/test/data/GoldenFiles/tez/TEZC-Rank-1.gld Thu Nov 27 12:49:54 2014 @@ -2,7 +2,7 @@ # There are 1 DAGs in the session #-------------------------------------------------- #-------------------------------------------------- -# TEZ DAG plan: scope-15 +# TEZ DAG plan: pig-0_scope-0 #-------------------------------------------------- Tez vertex scope-11 -> Tez vertex scope-14,Tez vertex scope-12, Tez vertex scope-12 -> Tez vertex scope-14, Modified: pig/branches/spark/test/org/apache/pig/test/data/GoldenFiles/tez/TEZC-Rank-2.gld URL: http://svn.apache.org/viewvc/pig/branches/spark/test/org/apache/pig/test/data/GoldenFiles/tez/TEZC-Rank-2.gld?rev=1642132&r1=1642131&r2=1642132&view=diff ============================================================================== --- pig/branches/spark/test/org/apache/pig/test/data/GoldenFiles/tez/TEZC-Rank-2.gld (original) +++ pig/branches/spark/test/org/apache/pig/test/data/GoldenFiles/tez/TEZC-Rank-2.gld Thu Nov 27 12:49:54 2014 @@ -2,7 +2,7 @@ # There are 1 DAGs in the session #-------------------------------------------------- #-------------------------------------------------- -# TEZ DAG plan: scope-52 +# TEZ DAG plan: pig-0_scope-0 #-------------------------------------------------- Tez vertex scope-23 -> Tez vertex scope-24, Tez vertex scope-24 -> Tez vertex scope-43,Tez vertex scope-33, @@ -62,7 +62,7 @@ POValueOutputTez - scope-42 -> [scope-4 | |---New For Each(false)[tuple] - scope-41 | | - | POUserFunc(org.apache.pig.backend.hadoop.executionengine.tez.FindQuantilesTez)[tuple] - scope-40 + | POUserFunc(org.apache.pig.backend.hadoop.executionengine.tez.plan.udf.FindQuantilesTez)[tuple] - scope-40 | | | |---Project[tuple][*] - scope-39 | Modified: pig/branches/spark/test/org/apache/pig/test/data/GoldenFiles/tez/TEZC-Union-1-OPTOFF.gld URL: http://svn.apache.org/viewvc/pig/branches/spark/test/org/apache/pig/test/data/GoldenFiles/tez/TEZC-Union-1-OPTOFF.gld?rev=1642132&r1=1642131&r2=1642132&view=diff ============================================================================== --- pig/branches/spark/test/org/apache/pig/test/data/GoldenFiles/tez/TEZC-Union-1-OPTOFF.gld (original) +++ pig/branches/spark/test/org/apache/pig/test/data/GoldenFiles/tez/TEZC-Union-1-OPTOFF.gld Thu Nov 27 12:49:54 2014 @@ -2,44 +2,44 @@ # There are 1 DAGs in the session #-------------------------------------------------- #-------------------------------------------------- -# TEZ DAG plan: scope-52 +# TEZ DAG plan: pig-0_scope-1 #-------------------------------------------------- -Tez vertex scope-46 -> Tez vertex scope-48, -Tez vertex scope-47 -> Tez vertex scope-48, -Tez vertex scope-48 +Tez vertex scope-45 -> Tez vertex scope-47, +Tez vertex scope-46 -> Tez vertex scope-47, +Tez vertex scope-47 -Tez vertex scope-46 +Tez vertex scope-45 # Plan on vertex -POValueOutputTez - scope-50 -> [scope-48] +POValueOutputTez - scope-49 -> [scope-47] | -|---a: New For Each(false,false)[bag] - scope-35 +|---a: New For Each(false,false)[bag] - scope-34 | | - | Cast[int] - scope-30 + | Cast[int] - scope-29 | | - | |---Project[bytearray][0] - scope-29 + | |---Project[bytearray][0] - scope-28 | | - | Cast[chararray] - scope-33 + | Cast[chararray] - scope-32 | | - | |---Project[bytearray][1] - scope-32 + | |---Project[bytearray][1] - scope-31 | - |---a: Load(file:///tmp/input:org.apache.pig.builtin.PigStorage) - scope-28 -Tez vertex scope-47 + |---a: Load(file:///tmp/input:org.apache.pig.builtin.PigStorage) - scope-27 +Tez vertex scope-46 # Plan on vertex -POValueOutputTez - scope-51 -> [scope-48] +POValueOutputTez - scope-50 -> [scope-47] | -|---c: New For Each(false,false)[bag] - scope-43 +|---c: New For Each(false,false)[bag] - scope-42 | | - | Cast[int] - scope-38 + | Cast[int] - scope-37 | | - | |---Project[bytearray][1] - scope-37 + | |---Project[bytearray][1] - scope-36 | | - | Cast[chararray] - scope-41 + | Cast[chararray] - scope-40 | | - | |---Project[bytearray][0] - scope-40 + | |---Project[bytearray][0] - scope-39 | - |---b: Load(file:///tmp/input:org.apache.pig.builtin.PigStorage) - scope-36 -Tez vertex scope-48 + |---b: Load(file:///tmp/input:org.apache.pig.builtin.PigStorage) - scope-35 +Tez vertex scope-47 # Plan on vertex -c: Store(file:///tmp/output:org.apache.pig.builtin.PigStorage) - scope-45 +c: Store(file:///tmp/output:org.apache.pig.builtin.PigStorage) - scope-44 | -|---POShuffledValueInputTez - scope-49 <- [scope-46, scope-47] +|---POShuffledValueInputTez - scope-48 <- [scope-46, scope-45] Modified: pig/branches/spark/test/org/apache/pig/test/data/GoldenFiles/tez/TEZC-Union-1.gld URL: http://svn.apache.org/viewvc/pig/branches/spark/test/org/apache/pig/test/data/GoldenFiles/tez/TEZC-Union-1.gld?rev=1642132&r1=1642131&r2=1642132&view=diff ============================================================================== --- pig/branches/spark/test/org/apache/pig/test/data/GoldenFiles/tez/TEZC-Union-1.gld (original) +++ pig/branches/spark/test/org/apache/pig/test/data/GoldenFiles/tez/TEZC-Union-1.gld Thu Nov 27 12:49:54 2014 @@ -2,15 +2,15 @@ # There are 1 DAGs in the session #-------------------------------------------------- #-------------------------------------------------- -# TEZ DAG plan: scope-24 +# TEZ DAG plan: pig-0_scope-0 #-------------------------------------------------- -Tez vertex scope-18 -> Tez vertex group scope-25, -Tez vertex scope-19 -> Tez vertex group scope-25, -Tez vertex group scope-25 +Tez vertex scope-18 -> Tez vertex group scope-24, +Tez vertex scope-19 -> Tez vertex group scope-24, +Tez vertex group scope-24 Tez vertex scope-18 # Plan on vertex -c: Store(file:///tmp/output:org.apache.pig.builtin.PigStorage) - scope-26 +c: Store(file:///tmp/output:org.apache.pig.builtin.PigStorage) - scope-25 | |---a: New For Each(false,false)[bag] - scope-7 | | @@ -25,7 +25,7 @@ c: Store(file:///tmp/output:org.apache.p |---a: Load(file:///tmp/input:org.apache.pig.builtin.PigStorage) - scope-0 Tez vertex scope-19 # Plan on vertex -c: Store(file:///tmp/output:org.apache.pig.builtin.PigStorage) - scope-27 +c: Store(file:///tmp/output:org.apache.pig.builtin.PigStorage) - scope-26 | |---c: New For Each(false,false)[bag] - scope-15 | | @@ -38,5 +38,5 @@ c: Store(file:///tmp/output:org.apache.p | |---Project[bytearray][0] - scope-12 | |---b: Load(file:///tmp/input:org.apache.pig.builtin.PigStorage) - scope-8 -Tez vertex group scope-25 <- [scope-18, scope-19] -> null +Tez vertex group scope-24 <- [scope-18, scope-19] -> null # No plan on vertex group Modified: pig/branches/spark/test/org/apache/pig/test/data/GoldenFiles/tez/TEZC-Union-10-OPTOFF.gld URL: http://svn.apache.org/viewvc/pig/branches/spark/test/org/apache/pig/test/data/GoldenFiles/tez/TEZC-Union-10-OPTOFF.gld?rev=1642132&r1=1642131&r2=1642132&view=diff ============================================================================== --- pig/branches/spark/test/org/apache/pig/test/data/GoldenFiles/tez/TEZC-Union-10-OPTOFF.gld (original) +++ pig/branches/spark/test/org/apache/pig/test/data/GoldenFiles/tez/TEZC-Union-10-OPTOFF.gld Thu Nov 27 12:49:54 2014 @@ -2,7 +2,7 @@ # There are 1 DAGs in the session #-------------------------------------------------- #-------------------------------------------------- -# TEZ DAG plan: scope-43 +# TEZ DAG plan: pig-0_scope-0 #-------------------------------------------------- Tez vertex scope-31 -> Tez vertex scope-33, Tez vertex scope-32 -> Tez vertex scope-33, Modified: pig/branches/spark/test/org/apache/pig/test/data/GoldenFiles/tez/TEZC-Union-10.gld URL: http://svn.apache.org/viewvc/pig/branches/spark/test/org/apache/pig/test/data/GoldenFiles/tez/TEZC-Union-10.gld?rev=1642132&r1=1642131&r2=1642132&view=diff ============================================================================== --- pig/branches/spark/test/org/apache/pig/test/data/GoldenFiles/tez/TEZC-Union-10.gld (original) +++ pig/branches/spark/test/org/apache/pig/test/data/GoldenFiles/tez/TEZC-Union-10.gld Thu Nov 27 12:49:54 2014 @@ -2,19 +2,19 @@ # There are 1 DAGs in the session #-------------------------------------------------- #-------------------------------------------------- -# TEZ DAG plan: scope-43 +# TEZ DAG plan: pig-0_scope-0 #-------------------------------------------------- -Tez vertex scope-37 -> Tez vertex group scope-44, -Tez vertex scope-31 -> Tez vertex group scope-44, -Tez vertex scope-32 -> Tez vertex group scope-44, -Tez vertex group scope-44 -> Tez vertex scope-42, +Tez vertex scope-37 -> Tez vertex group scope-43, +Tez vertex scope-31 -> Tez vertex group scope-43, +Tez vertex scope-32 -> Tez vertex group scope-43, +Tez vertex group scope-43 -> Tez vertex scope-42, Tez vertex scope-42 Tez vertex scope-37 # Plan on vertex -f: Local Rearrange[tuple]{int}(false) - scope-47 -> scope-42 +f: Local Rearrange[tuple]{int}(false) - scope-46 -> scope-42 | | -| Project[int][0] - scope-48 +| Project[int][0] - scope-47 | |---d: New For Each(false,false)[bag] - scope-24 | | @@ -29,9 +29,9 @@ f: Local Rearrange[tuple]{int}(false) - |---d: Load(file:///tmp/input1:org.apache.pig.builtin.PigStorage) - scope-17 Tez vertex scope-31 # Plan on vertex -f: Local Rearrange[tuple]{int}(false) - scope-50 -> scope-42 +f: Local Rearrange[tuple]{int}(false) - scope-49 -> scope-42 | | -| Project[int][0] - scope-51 +| Project[int][0] - scope-50 | |---a: New For Each(false,false)[bag] - scope-7 | | @@ -46,9 +46,9 @@ f: Local Rearrange[tuple]{int}(false) - |---a: Load(file:///tmp/input:org.apache.pig.builtin.PigStorage) - scope-0 Tez vertex scope-32 # Plan on vertex -f: Local Rearrange[tuple]{int}(false) - scope-52 -> scope-42 +f: Local Rearrange[tuple]{int}(false) - scope-51 -> scope-42 | | -| Project[int][0] - scope-53 +| Project[int][0] - scope-52 | |---c: New For Each(false,false)[bag] - scope-15 | | @@ -61,7 +61,7 @@ f: Local Rearrange[tuple]{int}(false) - | |---Project[bytearray][0] - scope-12 | |---b: Load(file:///tmp/input:org.apache.pig.builtin.PigStorage) - scope-8 -Tez vertex group scope-44 <- [scope-37, scope-31, scope-32] -> scope-42 +Tez vertex group scope-43 <- [scope-37, scope-31, scope-32] -> scope-42 # No plan on vertex group Tez vertex scope-42 # Plan on vertex Modified: pig/branches/spark/test/org/apache/pig/test/data/GoldenFiles/tez/TEZC-Union-2-OPTOFF.gld URL: http://svn.apache.org/viewvc/pig/branches/spark/test/org/apache/pig/test/data/GoldenFiles/tez/TEZC-Union-2-OPTOFF.gld?rev=1642132&r1=1642131&r2=1642132&view=diff ============================================================================== --- pig/branches/spark/test/org/apache/pig/test/data/GoldenFiles/tez/TEZC-Union-2-OPTOFF.gld (original) +++ pig/branches/spark/test/org/apache/pig/test/data/GoldenFiles/tez/TEZC-Union-2-OPTOFF.gld Thu Nov 27 12:49:54 2014 @@ -2,86 +2,86 @@ # There are 1 DAGs in the session #-------------------------------------------------- #-------------------------------------------------- -# TEZ DAG plan: scope-109 +# TEZ DAG plan: pig-0_scope-1 #-------------------------------------------------- -Tez vertex scope-102 -> Tez vertex scope-104, -Tez vertex scope-103 -> Tez vertex scope-104, -Tez vertex scope-104 -> Tez vertex scope-108, -Tez vertex scope-108 +Tez vertex scope-101 -> Tez vertex scope-103, +Tez vertex scope-102 -> Tez vertex scope-103, +Tez vertex scope-103 -> Tez vertex scope-107, +Tez vertex scope-107 -Tez vertex scope-102 +Tez vertex scope-101 # Plan on vertex -POValueOutputTez - scope-106 -> [scope-104] +POValueOutputTez - scope-105 -> [scope-103] | -|---a: New For Each(false,false)[bag] - scope-80 +|---a: New For Each(false,false)[bag] - scope-79 | | - | Cast[int] - scope-75 + | Cast[int] - scope-74 | | - | |---Project[bytearray][0] - scope-74 + | |---Project[bytearray][0] - scope-73 | | - | Cast[int] - scope-78 + | Cast[int] - scope-77 | | - | |---Project[bytearray][1] - scope-77 + | |---Project[bytearray][1] - scope-76 | - |---a: Load(file:///tmp/input:org.apache.pig.builtin.PigStorage) - scope-73 -Tez vertex scope-103 + |---a: Load(file:///tmp/input:org.apache.pig.builtin.PigStorage) - scope-72 +Tez vertex scope-102 # Plan on vertex -POValueOutputTez - scope-107 -> [scope-104] +POValueOutputTez - scope-106 -> [scope-103] | -|---c: New For Each(false,false)[bag] - scope-88 +|---c: New For Each(false,false)[bag] - scope-87 | | - | Cast[int] - scope-83 + | Cast[int] - scope-82 | | - | |---Project[bytearray][1] - scope-82 + | |---Project[bytearray][1] - scope-81 | | - | Cast[int] - scope-86 + | Cast[int] - scope-85 | | - | |---Project[bytearray][0] - scope-85 + | |---Project[bytearray][0] - scope-84 | - |---b: Load(file:///tmp/input:org.apache.pig.builtin.PigStorage) - scope-81 -Tez vertex scope-104 + |---b: Load(file:///tmp/input:org.apache.pig.builtin.PigStorage) - scope-80 +Tez vertex scope-103 # Plan on vertex -d: Local Rearrange[tuple]{int}(false) - scope-122 -> scope-108 +d: Local Rearrange[tuple]{int}(false) - scope-120 -> scope-107 | | -| Project[int][0] - scope-124 +| Project[int][0] - scope-122 | -|---e: New For Each(false,false)[bag] - scope-110 +|---e: New For Each(false,false)[bag] - scope-108 | | - | Project[int][0] - scope-111 + | Project[int][0] - scope-109 | | - | POUserFunc(org.apache.pig.builtin.AlgebraicMathBase$Initial)[tuple] - scope-112 + | POUserFunc(org.apache.pig.builtin.AlgebraicMathBase$Initial)[tuple] - scope-110 | | - | |---Project[bag][1] - scope-113 + | |---Project[bag][1] - scope-111 | | - | |---Project[bag][1] - scope-114 + | |---Project[bag][1] - scope-112 | - |---Pre Combiner Local Rearrange[tuple]{Unknown} - scope-125 + |---Pre Combiner Local Rearrange[tuple]{Unknown} - scope-123 | - |---POShuffledValueInputTez - scope-105 <- [scope-102, scope-103] -Tez vertex scope-108 -# Combine plan on edge <scope-104> -d: Local Rearrange[tuple]{int}(false) - scope-126 -> scope-108 + |---POShuffledValueInputTez - scope-104 <- [scope-102, scope-101] +Tez vertex scope-107 +# Combine plan on edge <scope-103> +d: Local Rearrange[tuple]{int}(false) - scope-124 -> scope-107 | | -| Project[int][0] - scope-128 +| Project[int][0] - scope-126 | -|---e: New For Each(false,false)[bag] - scope-115 +|---e: New For Each(false,false)[bag] - scope-113 | | - | Project[int][0] - scope-116 + | Project[int][0] - scope-114 | | - | POUserFunc(org.apache.pig.builtin.LongSum$Intermediate)[tuple] - scope-117 + | POUserFunc(org.apache.pig.builtin.LongSum$Intermediate)[tuple] - scope-115 | | - | |---Project[bag][1] - scope-118 + | |---Project[bag][1] - scope-116 | - |---d: Package(CombinerPackager)[tuple]{int} - scope-121 + |---d: Package(CombinerPackager)[tuple]{int} - scope-119 # Plan on vertex -e: Store(file:///tmp/output:org.apache.pig.builtin.PigStorage) - scope-101 +e: Store(file:///tmp/output:org.apache.pig.builtin.PigStorage) - scope-100 | -|---e: New For Each(false,false)[bag] - scope-100 +|---e: New For Each(false,false)[bag] - scope-99 | | - | Project[int][0] - scope-94 + | Project[int][0] - scope-93 | | - | POUserFunc(org.apache.pig.builtin.LongSum$Final)[long] - scope-98 + | POUserFunc(org.apache.pig.builtin.LongSum$Final)[long] - scope-97 | | - | |---Project[bag][1] - scope-119 + | |---Project[bag][1] - scope-117 | - |---d: Package(CombinerPackager)[tuple]{int} - scope-91 + |---d: Package(CombinerPackager)[tuple]{int} - scope-90 Modified: pig/branches/spark/test/org/apache/pig/test/data/GoldenFiles/tez/TEZC-Union-2.gld URL: http://svn.apache.org/viewvc/pig/branches/spark/test/org/apache/pig/test/data/GoldenFiles/tez/TEZC-Union-2.gld?rev=1642132&r1=1642131&r2=1642132&view=diff ============================================================================== --- pig/branches/spark/test/org/apache/pig/test/data/GoldenFiles/tez/TEZC-Union-2.gld (original) +++ pig/branches/spark/test/org/apache/pig/test/data/GoldenFiles/tez/TEZC-Union-2.gld Thu Nov 27 12:49:54 2014 @@ -2,30 +2,30 @@ # There are 1 DAGs in the session #-------------------------------------------------- #-------------------------------------------------- -# TEZ DAG plan: scope-36 +# TEZ DAG plan: pig-0_scope-0 #-------------------------------------------------- -Tez vertex scope-29 -> Tez vertex group scope-56, -Tez vertex scope-30 -> Tez vertex group scope-56, -Tez vertex group scope-56 -> Tez vertex scope-35, +Tez vertex scope-29 -> Tez vertex group scope-55, +Tez vertex scope-30 -> Tez vertex group scope-55, +Tez vertex group scope-55 -> Tez vertex scope-35, Tez vertex scope-35 Tez vertex scope-29 # Plan on vertex -d: Local Rearrange[tuple]{int}(false) - scope-57 -> scope-35 +d: Local Rearrange[tuple]{int}(false) - scope-56 -> scope-35 | | -| Project[int][0] - scope-58 +| Project[int][0] - scope-57 | -|---e: New For Each(false,false)[bag] - scope-63 +|---e: New For Each(false,false)[bag] - scope-62 | | - | Project[int][0] - scope-59 + | Project[int][0] - scope-58 | | - | POUserFunc(org.apache.pig.builtin.AlgebraicMathBase$Initial)[tuple] - scope-60 + | POUserFunc(org.apache.pig.builtin.AlgebraicMathBase$Initial)[tuple] - scope-59 | | - | |---Project[bag][1] - scope-62 + | |---Project[bag][1] - scope-60 | | | |---Project[bag][1] - scope-61 | - |---Pre Combiner Local Rearrange[tuple]{Unknown} - scope-64 + |---Pre Combiner Local Rearrange[tuple]{Unknown} - scope-63 | |---a: New For Each(false,false)[bag] - scope-7 | | @@ -40,21 +40,21 @@ d: Local Rearrange[tuple]{int}(false) - |---a: Load(file:///tmp/input:org.apache.pig.builtin.PigStorage) - scope-0 Tez vertex scope-30 # Plan on vertex -d: Local Rearrange[tuple]{int}(false) - scope-65 -> scope-35 +d: Local Rearrange[tuple]{int}(false) - scope-64 -> scope-35 | | -| Project[int][0] - scope-66 +| Project[int][0] - scope-65 | -|---e: New For Each(false,false)[bag] - scope-71 +|---e: New For Each(false,false)[bag] - scope-70 | | - | Project[int][0] - scope-67 + | Project[int][0] - scope-66 | | - | POUserFunc(org.apache.pig.builtin.AlgebraicMathBase$Initial)[tuple] - scope-68 + | POUserFunc(org.apache.pig.builtin.AlgebraicMathBase$Initial)[tuple] - scope-67 | | - | |---Project[bag][1] - scope-70 + | |---Project[bag][1] - scope-68 | | | |---Project[bag][1] - scope-69 | - |---Pre Combiner Local Rearrange[tuple]{Unknown} - scope-72 + |---Pre Combiner Local Rearrange[tuple]{Unknown} - scope-71 | |---c: New For Each(false,false)[bag] - scope-15 | | @@ -67,37 +67,37 @@ d: Local Rearrange[tuple]{int}(false) - | |---Project[bytearray][0] - scope-12 | |---b: Load(file:///tmp/input:org.apache.pig.builtin.PigStorage) - scope-8 -Tez vertex group scope-56 <- [scope-29, scope-30] -> scope-35 +Tez vertex group scope-55 <- [scope-29, scope-30] -> scope-35 # No plan on vertex group Tez vertex scope-35 # Combine plan on edge <scope-30> -d: Local Rearrange[tuple]{int}(false) - scope-53 -> scope-35 +d: Local Rearrange[tuple]{int}(false) - scope-52 -> scope-35 | | -| Project[int][0] - scope-55 +| Project[int][0] - scope-54 | -|---e: New For Each(false,false)[bag] - scope-42 +|---e: New For Each(false,false)[bag] - scope-41 | | - | Project[int][0] - scope-43 + | Project[int][0] - scope-42 | | - | POUserFunc(org.apache.pig.builtin.LongSum$Intermediate)[tuple] - scope-44 + | POUserFunc(org.apache.pig.builtin.LongSum$Intermediate)[tuple] - scope-43 | | - | |---Project[bag][1] - scope-45 + | |---Project[bag][1] - scope-44 | - |---d: Package(CombinerPackager)[tuple]{int} - scope-48 + |---d: Package(CombinerPackager)[tuple]{int} - scope-47 # Combine plan on edge <scope-29> -d: Local Rearrange[tuple]{int}(false) - scope-53 -> scope-35 +d: Local Rearrange[tuple]{int}(false) - scope-52 -> scope-35 | | -| Project[int][0] - scope-55 +| Project[int][0] - scope-54 | -|---e: New For Each(false,false)[bag] - scope-42 +|---e: New For Each(false,false)[bag] - scope-41 | | - | Project[int][0] - scope-43 + | Project[int][0] - scope-42 | | - | POUserFunc(org.apache.pig.builtin.LongSum$Intermediate)[tuple] - scope-44 + | POUserFunc(org.apache.pig.builtin.LongSum$Intermediate)[tuple] - scope-43 | | - | |---Project[bag][1] - scope-45 + | |---Project[bag][1] - scope-44 | - |---d: Package(CombinerPackager)[tuple]{int} - scope-48 + |---d: Package(CombinerPackager)[tuple]{int} - scope-47 # Plan on vertex e: Store(file:///tmp/output:org.apache.pig.builtin.PigStorage) - scope-28 | @@ -107,6 +107,6 @@ e: Store(file:///tmp/output:org.apache.p | | | POUserFunc(org.apache.pig.builtin.LongSum$Final)[long] - scope-25 | | - | |---Project[bag][1] - scope-46 + | |---Project[bag][1] - scope-45 | |---d: Package(CombinerPackager)[tuple]{int} - scope-18 Modified: pig/branches/spark/test/org/apache/pig/test/data/GoldenFiles/tez/TEZC-Union-3-OPTOFF.gld URL: http://svn.apache.org/viewvc/pig/branches/spark/test/org/apache/pig/test/data/GoldenFiles/tez/TEZC-Union-3-OPTOFF.gld?rev=1642132&r1=1642131&r2=1642132&view=diff ============================================================================== --- pig/branches/spark/test/org/apache/pig/test/data/GoldenFiles/tez/TEZC-Union-3-OPTOFF.gld (original) +++ pig/branches/spark/test/org/apache/pig/test/data/GoldenFiles/tez/TEZC-Union-3-OPTOFF.gld Thu Nov 27 12:49:54 2014 @@ -2,76 +2,76 @@ # There are 1 DAGs in the session #-------------------------------------------------- #-------------------------------------------------- -# TEZ DAG plan: scope-96 +# TEZ DAG plan: pig-0_scope-1 #-------------------------------------------------- -Tez vertex scope-88 -> Tez vertex scope-90, -Tez vertex scope-89 -> Tez vertex scope-90, -Tez vertex scope-90 -> Tez vertex scope-95, -Tez vertex scope-94 -> Tez vertex scope-95, -Tez vertex scope-95 +Tez vertex scope-87 -> Tez vertex scope-89, +Tez vertex scope-88 -> Tez vertex scope-89, +Tez vertex scope-89 -> Tez vertex scope-94, +Tez vertex scope-93 -> Tez vertex scope-94, +Tez vertex scope-94 -Tez vertex scope-88 +Tez vertex scope-87 # Plan on vertex -POValueOutputTez - scope-92 -> [scope-90] +POValueOutputTez - scope-91 -> [scope-89] | -|---a: New For Each(false,false)[bag] - scope-58 +|---a: New For Each(false,false)[bag] - scope-57 | | - | Cast[int] - scope-53 + | Cast[int] - scope-52 | | - | |---Project[bytearray][0] - scope-52 + | |---Project[bytearray][0] - scope-51 | | - | Cast[chararray] - scope-56 + | Cast[chararray] - scope-55 | | - | |---Project[bytearray][1] - scope-55 + | |---Project[bytearray][1] - scope-54 | - |---a: Load(file:///tmp/input:org.apache.pig.builtin.PigStorage) - scope-51 -Tez vertex scope-89 + |---a: Load(file:///tmp/input:org.apache.pig.builtin.PigStorage) - scope-50 +Tez vertex scope-88 # Plan on vertex -POValueOutputTez - scope-93 -> [scope-90] +POValueOutputTez - scope-92 -> [scope-89] | -|---c: New For Each(false,false)[bag] - scope-66 +|---c: New For Each(false,false)[bag] - scope-65 | | - | Cast[int] - scope-61 + | Cast[int] - scope-60 | | - | |---Project[bytearray][1] - scope-60 + | |---Project[bytearray][1] - scope-59 | | - | Cast[chararray] - scope-64 + | Cast[chararray] - scope-63 | | - | |---Project[bytearray][0] - scope-63 + | |---Project[bytearray][0] - scope-62 | - |---b: Load(file:///tmp/input:org.apache.pig.builtin.PigStorage) - scope-59 -Tez vertex scope-90 + |---b: Load(file:///tmp/input:org.apache.pig.builtin.PigStorage) - scope-58 +Tez vertex scope-89 # Plan on vertex -e: Local Rearrange[tuple]{int}(false) - scope-80 -> scope-95 +e: Local Rearrange[tuple]{int}(false) - scope-79 -> scope-94 | | -| Project[int][0] - scope-81 +| Project[int][0] - scope-80 | -|---POShuffledValueInputTez - scope-91 <- [scope-88, scope-89] -Tez vertex scope-94 +|---POShuffledValueInputTez - scope-90 <- [scope-87, scope-88] +Tez vertex scope-93 # Plan on vertex -e: Local Rearrange[tuple]{int}(false) - scope-82 -> scope-95 +e: Local Rearrange[tuple]{int}(false) - scope-81 -> scope-94 | | -| Project[int][0] - scope-83 +| Project[int][0] - scope-82 | -|---d: New For Each(false,false)[bag] - scope-75 +|---d: New For Each(false,false)[bag] - scope-74 | | - | Cast[int] - scope-70 + | Cast[int] - scope-69 | | - | |---Project[bytearray][0] - scope-69 + | |---Project[bytearray][0] - scope-68 | | - | Cast[chararray] - scope-73 + | Cast[chararray] - scope-72 | | - | |---Project[bytearray][1] - scope-72 + | |---Project[bytearray][1] - scope-71 | - |---d: Load(file:///tmp/input1:org.apache.pig.builtin.PigStorage) - scope-68 -Tez vertex scope-95 + |---d: Load(file:///tmp/input1:org.apache.pig.builtin.PigStorage) - scope-67 +Tez vertex scope-94 # Plan on vertex -e: Store(file:///tmp/output:org.apache.pig.builtin.PigStorage) - scope-87 +e: Store(file:///tmp/output:org.apache.pig.builtin.PigStorage) - scope-86 | -|---e: New For Each(true,true)[tuple] - scope-86 +|---e: New For Each(true,true)[tuple] - scope-85 | | - | Project[bag][1] - scope-84 + | Project[bag][1] - scope-83 | | - | Project[bag][2] - scope-85 + | Project[bag][2] - scope-84 | - |---e: Package(Packager)[tuple]{int} - scope-79 + |---e: Package(Packager)[tuple]{int} - scope-78 Modified: pig/branches/spark/test/org/apache/pig/test/data/GoldenFiles/tez/TEZC-Union-3.gld URL: http://svn.apache.org/viewvc/pig/branches/spark/test/org/apache/pig/test/data/GoldenFiles/tez/TEZC-Union-3.gld?rev=1642132&r1=1642131&r2=1642132&view=diff ============================================================================== --- pig/branches/spark/test/org/apache/pig/test/data/GoldenFiles/tez/TEZC-Union-3.gld (original) +++ pig/branches/spark/test/org/apache/pig/test/data/GoldenFiles/tez/TEZC-Union-3.gld Thu Nov 27 12:49:54 2014 @@ -2,12 +2,12 @@ # There are 1 DAGs in the session #-------------------------------------------------- #-------------------------------------------------- -# TEZ DAG plan: scope-45 +# TEZ DAG plan: pig-0_scope-0 #-------------------------------------------------- Tez vertex scope-43 -> Tez vertex scope-44, -Tez vertex scope-37 -> Tez vertex group scope-46, -Tez vertex scope-38 -> Tez vertex group scope-46, -Tez vertex group scope-46 -> Tez vertex scope-44, +Tez vertex scope-37 -> Tez vertex group scope-45, +Tez vertex scope-38 -> Tez vertex group scope-45, +Tez vertex group scope-45 -> Tez vertex scope-44, Tez vertex scope-44 Tez vertex scope-43 @@ -29,9 +29,9 @@ e: Local Rearrange[tuple]{int}(false) - |---d: Load(file:///tmp/input1:org.apache.pig.builtin.PigStorage) - scope-17 Tez vertex scope-37 # Plan on vertex -e: Local Rearrange[tuple]{int}(false) - scope-47 -> scope-44 +e: Local Rearrange[tuple]{int}(false) - scope-46 -> scope-44 | | -| Project[int][0] - scope-48 +| Project[int][0] - scope-47 | |---a: New For Each(false,false)[bag] - scope-7 | | @@ -46,9 +46,9 @@ e: Local Rearrange[tuple]{int}(false) - |---a: Load(file:///tmp/input:org.apache.pig.builtin.PigStorage) - scope-0 Tez vertex scope-38 # Plan on vertex -e: Local Rearrange[tuple]{int}(false) - scope-49 -> scope-44 +e: Local Rearrange[tuple]{int}(false) - scope-48 -> scope-44 | | -| Project[int][0] - scope-50 +| Project[int][0] - scope-49 | |---c: New For Each(false,false)[bag] - scope-15 | | @@ -61,7 +61,7 @@ e: Local Rearrange[tuple]{int}(false) - | |---Project[bytearray][0] - scope-12 | |---b: Load(file:///tmp/input:org.apache.pig.builtin.PigStorage) - scope-8 -Tez vertex group scope-46 <- [scope-37, scope-38] -> scope-44 +Tez vertex group scope-45 <- [scope-37, scope-38] -> scope-44 # No plan on vertex group Tez vertex scope-44 # Plan on vertex Modified: pig/branches/spark/test/org/apache/pig/test/data/GoldenFiles/tez/TEZC-Union-4-OPTOFF.gld URL: http://svn.apache.org/viewvc/pig/branches/spark/test/org/apache/pig/test/data/GoldenFiles/tez/TEZC-Union-4-OPTOFF.gld?rev=1642132&r1=1642131&r2=1642132&view=diff ============================================================================== --- pig/branches/spark/test/org/apache/pig/test/data/GoldenFiles/tez/TEZC-Union-4-OPTOFF.gld (original) +++ pig/branches/spark/test/org/apache/pig/test/data/GoldenFiles/tez/TEZC-Union-4-OPTOFF.gld Thu Nov 27 12:49:54 2014 @@ -2,68 +2,68 @@ # There are 1 DAGs in the session #-------------------------------------------------- #-------------------------------------------------- -# TEZ DAG plan: scope-83 +# TEZ DAG plan: pig-0_scope-1 #-------------------------------------------------- -Tez vertex scope-76 -> Tez vertex scope-78, -Tez vertex scope-77 -> Tez vertex scope-78, -Tez vertex scope-82 -> Tez vertex scope-78, -Tez vertex scope-78 +Tez vertex scope-75 -> Tez vertex scope-77, +Tez vertex scope-76 -> Tez vertex scope-77, +Tez vertex scope-81 -> Tez vertex scope-77, +Tez vertex scope-77 -Tez vertex scope-76 +Tez vertex scope-75 # Plan on vertex -POValueOutputTez - scope-80 -> [scope-78] +POValueOutputTez - scope-79 -> [scope-77] | -|---a: New For Each(false,false)[bag] - scope-49 +|---a: New For Each(false,false)[bag] - scope-48 | | - | Cast[int] - scope-44 + | Cast[int] - scope-43 | | - | |---Project[bytearray][0] - scope-43 + | |---Project[bytearray][0] - scope-42 | | - | Cast[chararray] - scope-47 + | Cast[chararray] - scope-46 | | - | |---Project[bytearray][1] - scope-46 + | |---Project[bytearray][1] - scope-45 | - |---a: Load(file:///tmp/input:org.apache.pig.builtin.PigStorage) - scope-42 -Tez vertex scope-77 + |---a: Load(file:///tmp/input:org.apache.pig.builtin.PigStorage) - scope-41 +Tez vertex scope-76 # Plan on vertex -POValueOutputTez - scope-81 -> [scope-78] +POValueOutputTez - scope-80 -> [scope-77] | -|---c: New For Each(false,false)[bag] - scope-57 +|---c: New For Each(false,false)[bag] - scope-56 | | - | Cast[int] - scope-52 + | Cast[int] - scope-51 | | - | |---Project[bytearray][1] - scope-51 + | |---Project[bytearray][1] - scope-50 | | - | Cast[chararray] - scope-55 + | Cast[chararray] - scope-54 | | - | |---Project[bytearray][0] - scope-54 + | |---Project[bytearray][0] - scope-53 | - |---b: Load(file:///tmp/input:org.apache.pig.builtin.PigStorage) - scope-50 -Tez vertex scope-82 + |---b: Load(file:///tmp/input:org.apache.pig.builtin.PigStorage) - scope-49 +Tez vertex scope-81 # Plan on vertex -Local Rearrange[tuple]{int}(false) - scope-72 -> scope-78 +Local Rearrange[tuple]{int}(false) - scope-71 -> scope-77 | | -| Project[int][0] - scope-68 +| Project[int][0] - scope-67 | -|---d: New For Each(false,false)[bag] - scope-66 +|---d: New For Each(false,false)[bag] - scope-65 | | - | Cast[int] - scope-61 + | Cast[int] - scope-60 | | - | |---Project[bytearray][0] - scope-60 + | |---Project[bytearray][0] - scope-59 | | - | Cast[chararray] - scope-64 + | Cast[chararray] - scope-63 | | - | |---Project[bytearray][1] - scope-63 + | |---Project[bytearray][1] - scope-62 | - |---d: Load(file:///tmp/input1:org.apache.pig.builtin.PigStorage) - scope-59 -Tez vertex scope-78 + |---d: Load(file:///tmp/input1:org.apache.pig.builtin.PigStorage) - scope-58 +Tez vertex scope-77 # Plan on vertex -e: Store(file:///tmp/output:org.apache.pig.builtin.PigStorage) - scope-75 +e: Store(file:///tmp/output:org.apache.pig.builtin.PigStorage) - scope-74 | -|---e: FRJoin[tuple] - scope-69 <- scope-82 +|---e: FRJoin[tuple] - scope-68 <- scope-81 | | - | Project[int][0] - scope-67 + | Project[int][0] - scope-66 | | - | Project[int][0] - scope-68 + | Project[int][0] - scope-67 | - |---POShuffledValueInputTez - scope-79 <- [scope-77, scope-76] + |---POShuffledValueInputTez - scope-78 <- [scope-76, scope-75] Modified: pig/branches/spark/test/org/apache/pig/test/data/GoldenFiles/tez/TEZC-Union-4.gld URL: http://svn.apache.org/viewvc/pig/branches/spark/test/org/apache/pig/test/data/GoldenFiles/tez/TEZC-Union-4.gld?rev=1642132&r1=1642131&r2=1642132&view=diff ============================================================================== --- pig/branches/spark/test/org/apache/pig/test/data/GoldenFiles/tez/TEZC-Union-4.gld (original) +++ pig/branches/spark/test/org/apache/pig/test/data/GoldenFiles/tez/TEZC-Union-4.gld Thu Nov 27 12:49:54 2014 @@ -2,7 +2,7 @@ # There are 1 DAGs in the session #-------------------------------------------------- #-------------------------------------------------- -# TEZ DAG plan: scope-41 +# TEZ DAG plan: pig-0_scope-0 #-------------------------------------------------- Tez vertex scope-34 -> Tez vertex scope-36, Tez vertex scope-35 -> Tez vertex scope-36, Modified: pig/branches/spark/test/org/apache/pig/test/data/GoldenFiles/tez/TEZC-Union-5-OPTOFF.gld URL: http://svn.apache.org/viewvc/pig/branches/spark/test/org/apache/pig/test/data/GoldenFiles/tez/TEZC-Union-5-OPTOFF.gld?rev=1642132&r1=1642131&r2=1642132&view=diff ============================================================================== --- pig/branches/spark/test/org/apache/pig/test/data/GoldenFiles/tez/TEZC-Union-5-OPTOFF.gld (original) +++ pig/branches/spark/test/org/apache/pig/test/data/GoldenFiles/tez/TEZC-Union-5-OPTOFF.gld Thu Nov 27 12:49:54 2014 @@ -2,68 +2,68 @@ # There are 1 DAGs in the session #-------------------------------------------------- #-------------------------------------------------- -# TEZ DAG plan: scope-172 +# TEZ DAG plan: pig-0_scope-3 #-------------------------------------------------- -Tez vertex scope-166 -> Tez vertex scope-168, -Tez vertex scope-167 -> Tez vertex scope-168, -Tez vertex scope-168 -> Tez vertex scope-165, -Tez vertex scope-165 +Tez vertex scope-163 -> Tez vertex scope-165, +Tez vertex scope-164 -> Tez vertex scope-165, +Tez vertex scope-165 -> Tez vertex scope-162, +Tez vertex scope-162 -Tez vertex scope-166 +Tez vertex scope-163 # Plan on vertex -POValueOutputTez - scope-170 -> [scope-168] +POValueOutputTez - scope-167 -> [scope-165] | -|---a: New For Each(false,false)[bag] - scope-146 +|---a: New For Each(false,false)[bag] - scope-143 | | - | Cast[int] - scope-141 + | Cast[int] - scope-138 | | - | |---Project[bytearray][0] - scope-140 + | |---Project[bytearray][0] - scope-137 | | - | Cast[chararray] - scope-144 + | Cast[chararray] - scope-141 | | - | |---Project[bytearray][1] - scope-143 + | |---Project[bytearray][1] - scope-140 | - |---a: Load(file:///tmp/input:org.apache.pig.builtin.PigStorage) - scope-139 -Tez vertex scope-167 + |---a: Load(file:///tmp/input:org.apache.pig.builtin.PigStorage) - scope-136 +Tez vertex scope-164 # Plan on vertex -POValueOutputTez - scope-171 -> [scope-168] +POValueOutputTez - scope-168 -> [scope-165] | -|---c: New For Each(false,false)[bag] - scope-154 +|---c: New For Each(false,false)[bag] - scope-151 | | - | Cast[int] - scope-149 + | Cast[int] - scope-146 | | - | |---Project[bytearray][1] - scope-148 + | |---Project[bytearray][1] - scope-145 | | - | Cast[chararray] - scope-152 + | Cast[chararray] - scope-149 | | - | |---Project[bytearray][0] - scope-151 + | |---Project[bytearray][0] - scope-148 | - |---b: Load(file:///tmp/input:org.apache.pig.builtin.PigStorage) - scope-147 -Tez vertex scope-168 + |---b: Load(file:///tmp/input:org.apache.pig.builtin.PigStorage) - scope-144 +Tez vertex scope-165 # Plan on vertex -Local Rearrange[tuple]{int}(false) - scope-161 -> scope-165 +Local Rearrange[tuple]{int}(false) - scope-158 -> scope-162 | | -| Project[int][0] - scope-157 +| Project[int][0] - scope-154 | -|---POShuffledValueInputTez - scope-169 <- [scope-166, scope-167] -Tez vertex scope-165 +|---POShuffledValueInputTez - scope-166 <- [scope-163, scope-164] +Tez vertex scope-162 # Plan on vertex -e: Store(file:///tmp/output:org.apache.pig.builtin.PigStorage) - scope-164 +e: Store(file:///tmp/output:org.apache.pig.builtin.PigStorage) - scope-161 | -|---e: FRJoin[tuple] - scope-158 <- scope-168 +|---e: FRJoin[tuple] - scope-155 <- scope-165 | | - | Project[int][0] - scope-156 + | Project[int][0] - scope-153 | | - | Project[int][0] - scope-157 + | Project[int][0] - scope-154 | - |---d: New For Each(false,false)[bag] - scope-138 + |---d: New For Each(false,false)[bag] - scope-135 | | - | Cast[int] - scope-133 + | Cast[int] - scope-130 | | - | |---Project[bytearray][0] - scope-132 + | |---Project[bytearray][0] - scope-129 | | - | Cast[chararray] - scope-136 + | Cast[chararray] - scope-133 | | - | |---Project[bytearray][1] - scope-135 + | |---Project[bytearray][1] - scope-132 | - |---d: Load(file:///tmp/input1:org.apache.pig.builtin.PigStorage) - scope-131 + |---d: Load(file:///tmp/input1:org.apache.pig.builtin.PigStorage) - scope-128 Modified: pig/branches/spark/test/org/apache/pig/test/data/GoldenFiles/tez/TEZC-Union-5.gld URL: http://svn.apache.org/viewvc/pig/branches/spark/test/org/apache/pig/test/data/GoldenFiles/tez/TEZC-Union-5.gld?rev=1642132&r1=1642131&r2=1642132&view=diff ============================================================================== --- pig/branches/spark/test/org/apache/pig/test/data/GoldenFiles/tez/TEZC-Union-5.gld (original) +++ pig/branches/spark/test/org/apache/pig/test/data/GoldenFiles/tez/TEZC-Union-5.gld Thu Nov 27 12:49:54 2014 @@ -2,67 +2,67 @@ # There are 1 DAGs in the session #-------------------------------------------------- #-------------------------------------------------- -# TEZ DAG plan: scope-125 +# TEZ DAG plan: pig-0_scope-2 #-------------------------------------------------- -Tez vertex scope-119 -> Tez vertex group scope-126, -Tez vertex scope-120 -> Tez vertex group scope-126, -Tez vertex group scope-126 -> Tez vertex scope-118, -Tez vertex scope-118 +Tez vertex scope-117 -> Tez vertex group scope-123, +Tez vertex scope-118 -> Tez vertex group scope-123, +Tez vertex group scope-123 -> Tez vertex scope-116, +Tez vertex scope-116 -Tez vertex scope-119 +Tez vertex scope-117 # Plan on vertex -Local Rearrange[tuple]{int}(false) - scope-127 -> scope-118 +Local Rearrange[tuple]{int}(false) - scope-124 -> scope-116 | | -| Project[int][0] - scope-128 +| Project[int][0] - scope-125 | -|---a: New For Each(false,false)[bag] - scope-99 +|---a: New For Each(false,false)[bag] - scope-97 | | - | Cast[int] - scope-94 + | Cast[int] - scope-92 | | - | |---Project[bytearray][0] - scope-93 + | |---Project[bytearray][0] - scope-91 | | - | Cast[chararray] - scope-97 + | Cast[chararray] - scope-95 | | - | |---Project[bytearray][1] - scope-96 + | |---Project[bytearray][1] - scope-94 | - |---a: Load(file:///tmp/input:org.apache.pig.builtin.PigStorage) - scope-92 -Tez vertex scope-120 + |---a: Load(file:///tmp/input:org.apache.pig.builtin.PigStorage) - scope-90 +Tez vertex scope-118 # Plan on vertex -Local Rearrange[tuple]{int}(false) - scope-129 -> scope-118 +Local Rearrange[tuple]{int}(false) - scope-126 -> scope-116 | | -| Project[int][0] - scope-130 +| Project[int][0] - scope-127 | -|---c: New For Each(false,false)[bag] - scope-107 +|---c: New For Each(false,false)[bag] - scope-105 | | - | Cast[int] - scope-102 + | Cast[int] - scope-100 | | - | |---Project[bytearray][1] - scope-101 + | |---Project[bytearray][1] - scope-99 | | - | Cast[chararray] - scope-105 + | Cast[chararray] - scope-103 | | - | |---Project[bytearray][0] - scope-104 + | |---Project[bytearray][0] - scope-102 | - |---b: Load(file:///tmp/input:org.apache.pig.builtin.PigStorage) - scope-100 -Tez vertex group scope-126 <- [scope-119, scope-120] -> scope-118 + |---b: Load(file:///tmp/input:org.apache.pig.builtin.PigStorage) - scope-98 +Tez vertex group scope-123 <- [scope-117, scope-118] -> scope-116 # No plan on vertex group -Tez vertex scope-118 +Tez vertex scope-116 # Plan on vertex -e: Store(file:///tmp/output:org.apache.pig.builtin.PigStorage) - scope-117 +e: Store(file:///tmp/output:org.apache.pig.builtin.PigStorage) - scope-115 | -|---e: FRJoin[tuple] - scope-111 <- scope-126 +|---e: FRJoin[tuple] - scope-109 <- scope-123 | | - | Project[int][0] - scope-109 + | Project[int][0] - scope-107 | | - | Project[int][0] - scope-110 + | Project[int][0] - scope-108 | - |---d: New For Each(false,false)[bag] - scope-91 + |---d: New For Each(false,false)[bag] - scope-89 | | - | Cast[int] - scope-86 + | Cast[int] - scope-84 | | - | |---Project[bytearray][0] - scope-85 + | |---Project[bytearray][0] - scope-83 | | - | Cast[chararray] - scope-89 + | Cast[chararray] - scope-87 | | - | |---Project[bytearray][1] - scope-88 + | |---Project[bytearray][1] - scope-86 | - |---d: Load(file:///tmp/input1:org.apache.pig.builtin.PigStorage) - scope-84 + |---d: Load(file:///tmp/input1:org.apache.pig.builtin.PigStorage) - scope-82 Modified: pig/branches/spark/test/org/apache/pig/test/data/GoldenFiles/tez/TEZC-Union-6-OPTOFF.gld URL: http://svn.apache.org/viewvc/pig/branches/spark/test/org/apache/pig/test/data/GoldenFiles/tez/TEZC-Union-6-OPTOFF.gld?rev=1642132&r1=1642131&r2=1642132&view=diff ============================================================================== --- pig/branches/spark/test/org/apache/pig/test/data/GoldenFiles/tez/TEZC-Union-6-OPTOFF.gld (original) +++ pig/branches/spark/test/org/apache/pig/test/data/GoldenFiles/tez/TEZC-Union-6-OPTOFF.gld Thu Nov 27 12:49:54 2014 @@ -2,114 +2,114 @@ # There are 1 DAGs in the session #-------------------------------------------------- #-------------------------------------------------- -# TEZ DAG plan: scope-148 +# TEZ DAG plan: pig-0_scope-1 #-------------------------------------------------- -Tez vertex scope-115 -> Tez vertex scope-117, -Tez vertex scope-116 -> Tez vertex scope-117, -Tez vertex scope-117 -> Tez vertex scope-139,Tez vertex scope-129, -Tez vertex scope-129 -> Tez vertex scope-139,Tez vertex scope-121, -Tez vertex scope-139 -> Tez vertex scope-143, -Tez vertex scope-121 -> Tez vertex scope-143, -Tez vertex scope-143 +Tez vertex scope-114 -> Tez vertex scope-116, +Tez vertex scope-115 -> Tez vertex scope-116, +Tez vertex scope-116 -> Tez vertex scope-138,Tez vertex scope-128, +Tez vertex scope-128 -> Tez vertex scope-138,Tez vertex scope-120, +Tez vertex scope-138 -> Tez vertex scope-142, +Tez vertex scope-120 -> Tez vertex scope-142, +Tez vertex scope-142 -Tez vertex scope-115 +Tez vertex scope-114 # Plan on vertex -POValueOutputTez - scope-119 -> [scope-117] +POValueOutputTez - scope-118 -> [scope-116] | -|---a: New For Each(false,false)[bag] - scope-93 +|---a: New For Each(false,false)[bag] - scope-92 | | - | Cast[int] - scope-88 + | Cast[int] - scope-87 | | - | |---Project[bytearray][0] - scope-87 + | |---Project[bytearray][0] - scope-86 | | - | Cast[chararray] - scope-91 + | Cast[chararray] - scope-90 | | - | |---Project[bytearray][1] - scope-90 + | |---Project[bytearray][1] - scope-89 | - |---a: Load(file:///tmp/input:org.apache.pig.builtin.PigStorage) - scope-86 -Tez vertex scope-116 + |---a: Load(file:///tmp/input:org.apache.pig.builtin.PigStorage) - scope-85 +Tez vertex scope-115 # Plan on vertex -POValueOutputTez - scope-120 -> [scope-117] +POValueOutputTez - scope-119 -> [scope-116] | -|---c: New For Each(false,false)[bag] - scope-101 +|---c: New For Each(false,false)[bag] - scope-100 | | - | Cast[int] - scope-96 + | Cast[int] - scope-95 | | - | |---Project[bytearray][1] - scope-95 + | |---Project[bytearray][1] - scope-94 | | - | Cast[chararray] - scope-99 + | Cast[chararray] - scope-98 | | - | |---Project[bytearray][0] - scope-98 + | |---Project[bytearray][0] - scope-97 | - |---b: Load(file:///tmp/input:org.apache.pig.builtin.PigStorage) - scope-94 -Tez vertex scope-117 + |---b: Load(file:///tmp/input:org.apache.pig.builtin.PigStorage) - scope-93 +Tez vertex scope-116 # Plan on vertex -Local Rearrange[tuple]{tuple}(false) - scope-124 -> scope-129 +Local Rearrange[tuple]{tuple}(false) - scope-123 -> scope-128 | | -| Constant(DummyVal) - scope-123 +| Constant(DummyVal) - scope-122 | -|---New For Each(true,true)[tuple] - scope-128 +|---New For Each(true,true)[tuple] - scope-127 | | - | Project[int][0] - scope-111 + | Project[int][0] - scope-110 | | - | POUserFunc(org.apache.pig.impl.builtin.GetMemNumRows)[tuple] - scope-127 + | POUserFunc(org.apache.pig.impl.builtin.GetMemNumRows)[tuple] - scope-126 | | - | |---Project[tuple][*] - scope-126 + | |---Project[tuple][*] - scope-125 | - |---PoissonSample - scope-125 + |---PoissonSample - scope-124 | - |---Local Rearrange[tuple]{int}(false) - scope-122 -> scope-139 + |---Local Rearrange[tuple]{int}(false) - scope-121 -> scope-138 | | - | Project[int][0] - scope-111 + | Project[int][0] - scope-110 | - |---POShuffledValueInputTez - scope-118 <- [scope-116, scope-115] -Tez vertex scope-129 + |---POShuffledValueInputTez - scope-117 <- [scope-114, scope-115] +Tez vertex scope-128 # Plan on vertex -POValueOutputTez - scope-138 -> [scope-139, scope-121] +POValueOutputTez - scope-137 -> [scope-138, scope-120] | -|---New For Each(false)[tuple] - scope-137 +|---New For Each(false)[tuple] - scope-136 | | - | POUserFunc(org.apache.pig.backend.hadoop.executionengine.tez.PartitionSkewedKeysTez)[tuple] - scope-136 + | POUserFunc(org.apache.pig.backend.hadoop.executionengine.tez.plan.udf.PartitionSkewedKeysTez)[tuple] - scope-135 | | - | |---Project[tuple][*] - scope-135 + | |---Project[tuple][*] - scope-134 | - |---New For Each(false,false)[tuple] - scope-134 + |---New For Each(false,false)[tuple] - scope-133 | | - | Constant(-1) - scope-133 + | Constant(-1) - scope-132 | | - | Project[bag][1] - scope-131 + | Project[bag][1] - scope-130 | - |---Package(Packager)[tuple]{bytearray} - scope-130 -Tez vertex scope-139 + |---Package(Packager)[tuple]{bytearray} - scope-129 +Tez vertex scope-138 # Plan on vertex -POIdentityInOutTez - scope-140 <- scope-117 -> scope-143 +POIdentityInOutTez - scope-139 <- scope-116 -> scope-142 | | -| Project[int][0] - scope-111 -Tez vertex scope-121 +| Project[int][0] - scope-110 +Tez vertex scope-120 # Plan on vertex -Partition Rearrange[tuple]{int}(false) - scope-141 -> scope-143 +Partition Rearrange[tuple]{int}(false) - scope-140 -> scope-142 | | -| Project[int][0] - scope-112 +| Project[int][0] - scope-111 | -|---d: New For Each(false,false)[bag] - scope-110 +|---d: New For Each(false,false)[bag] - scope-109 | | - | Cast[int] - scope-105 + | Cast[int] - scope-104 | | - | |---Project[bytearray][0] - scope-104 + | |---Project[bytearray][0] - scope-103 | | - | Cast[chararray] - scope-108 + | Cast[chararray] - scope-107 | | - | |---Project[bytearray][1] - scope-107 + | |---Project[bytearray][1] - scope-106 | - |---d: Load(file:///tmp/input1:org.apache.pig.builtin.PigStorage) - scope-103 -Tez vertex scope-143 + |---d: Load(file:///tmp/input1:org.apache.pig.builtin.PigStorage) - scope-102 +Tez vertex scope-142 # Plan on vertex -e: Store(file:///tmp/output:org.apache.pig.builtin.PigStorage) - scope-114 +e: Store(file:///tmp/output:org.apache.pig.builtin.PigStorage) - scope-113 | -|---New For Each(true,true)[tuple] - scope-147 +|---New For Each(true,true)[tuple] - scope-146 | | - | Project[bag][1] - scope-145 + | Project[bag][1] - scope-144 | | - | Project[bag][2] - scope-146 + | Project[bag][2] - scope-145 | - |---Package(Packager)[tuple]{int} - scope-144 + |---Package(Packager)[tuple]{int} - scope-143 Modified: pig/branches/spark/test/org/apache/pig/test/data/GoldenFiles/tez/TEZC-Union-6.gld URL: http://svn.apache.org/viewvc/pig/branches/spark/test/org/apache/pig/test/data/GoldenFiles/tez/TEZC-Union-6.gld?rev=1642132&r1=1642131&r2=1642132&view=diff ============================================================================== --- pig/branches/spark/test/org/apache/pig/test/data/GoldenFiles/tez/TEZC-Union-6.gld (original) +++ pig/branches/spark/test/org/apache/pig/test/data/GoldenFiles/tez/TEZC-Union-6.gld Thu Nov 27 12:49:54 2014 @@ -2,36 +2,36 @@ # There are 1 DAGs in the session #-------------------------------------------------- #-------------------------------------------------- -# TEZ DAG plan: scope-62 +# TEZ DAG plan: pig-0_scope-0 #-------------------------------------------------- -Tez vertex scope-29 -> Tez vertex group scope-64,Tez vertex group scope-65, -Tez vertex scope-30 -> Tez vertex group scope-64,Tez vertex group scope-65, -Tez vertex group scope-65 -> Tez vertex scope-43, +Tez vertex scope-29 -> Tez vertex group scope-63,Tez vertex group scope-64, +Tez vertex scope-30 -> Tez vertex group scope-63,Tez vertex group scope-64, +Tez vertex group scope-64 -> Tez vertex scope-43, Tez vertex scope-43 -> Tez vertex scope-53,Tez vertex scope-35, -Tez vertex group scope-64 -> Tez vertex scope-53, +Tez vertex group scope-63 -> Tez vertex scope-53, Tez vertex scope-53 -> Tez vertex scope-57, Tez vertex scope-35 -> Tez vertex scope-57, Tez vertex scope-57 Tez vertex scope-29 # Plan on vertex -Local Rearrange[tuple]{tuple}(false) - scope-68 -> scope-43 +Local Rearrange[tuple]{tuple}(false) - scope-67 -> scope-43 | | -| Constant(DummyVal) - scope-69 +| Constant(DummyVal) - scope-68 | -|---New For Each(true,true)[tuple] - scope-75 +|---New For Each(true,true)[tuple] - scope-74 | | - | Project[int][0] - scope-72 + | Project[int][0] - scope-71 | | - | POUserFunc(org.apache.pig.impl.builtin.GetMemNumRows)[tuple] - scope-73 + | POUserFunc(org.apache.pig.impl.builtin.GetMemNumRows)[tuple] - scope-72 | | - | |---Project[tuple][*] - scope-74 + | |---Project[tuple][*] - scope-73 | - |---PoissonSample - scope-71 + |---PoissonSample - scope-70 | - |---Local Rearrange[tuple]{int}(false) - scope-66 -> scope-53 + |---Local Rearrange[tuple]{int}(false) - scope-65 -> scope-53 | | - | Project[int][0] - scope-67 + | Project[int][0] - scope-66 | |---a: New For Each(false,false)[bag] - scope-7 | | @@ -46,23 +46,23 @@ Local Rearrange[tuple]{tuple}(false) - s |---a: Load(file:///tmp/input:org.apache.pig.builtin.PigStorage) - scope-0 Tez vertex scope-30 # Plan on vertex -Local Rearrange[tuple]{tuple}(false) - scope-78 -> scope-43 +Local Rearrange[tuple]{tuple}(false) - scope-77 -> scope-43 | | -| Constant(DummyVal) - scope-79 +| Constant(DummyVal) - scope-78 | -|---New For Each(true,true)[tuple] - scope-85 +|---New For Each(true,true)[tuple] - scope-84 | | - | Project[int][0] - scope-82 + | Project[int][0] - scope-81 | | - | POUserFunc(org.apache.pig.impl.builtin.GetMemNumRows)[tuple] - scope-83 + | POUserFunc(org.apache.pig.impl.builtin.GetMemNumRows)[tuple] - scope-82 | | - | |---Project[tuple][*] - scope-84 + | |---Project[tuple][*] - scope-83 | - |---PoissonSample - scope-81 + |---PoissonSample - scope-80 | - |---Local Rearrange[tuple]{int}(false) - scope-76 -> scope-53 + |---Local Rearrange[tuple]{int}(false) - scope-75 -> scope-53 | | - | Project[int][0] - scope-77 + | Project[int][0] - scope-76 | |---c: New For Each(false,false)[bag] - scope-15 | | @@ -75,7 +75,7 @@ Local Rearrange[tuple]{tuple}(false) - s | |---Project[bytearray][0] - scope-12 | |---b: Load(file:///tmp/input:org.apache.pig.builtin.PigStorage) - scope-8 -Tez vertex group scope-65 <- [scope-29, scope-30] -> scope-43 +Tez vertex group scope-64 <- [scope-29, scope-30] -> scope-43 # No plan on vertex group Tez vertex scope-43 # Plan on vertex @@ -83,7 +83,7 @@ POValueOutputTez - scope-52 -> [scope-5 | |---New For Each(false)[tuple] - scope-51 | | - | POUserFunc(org.apache.pig.backend.hadoop.executionengine.tez.PartitionSkewedKeysTez)[tuple] - scope-50 + | POUserFunc(org.apache.pig.backend.hadoop.executionengine.tez.plan.udf.PartitionSkewedKeysTez)[tuple] - scope-50 | | | |---Project[tuple][*] - scope-49 | @@ -94,11 +94,11 @@ POValueOutputTez - scope-52 -> [scope-5 | Project[bag][1] - scope-45 | |---Package(Packager)[tuple]{bytearray} - scope-44 -Tez vertex group scope-64 <- [scope-29, scope-30] -> scope-53 +Tez vertex group scope-63 <- [scope-29, scope-30] -> scope-53 # No plan on vertex group Tez vertex scope-53 # Plan on vertex -POIdentityInOutTez - scope-54 <- scope-64 -> scope-57 +POIdentityInOutTez - scope-54 <- scope-63 -> scope-57 | | | Project[int][0] - scope-25 Tez vertex scope-35 Modified: pig/branches/spark/test/org/apache/pig/test/data/GoldenFiles/tez/TEZC-Union-7-OPTOFF.gld URL: http://svn.apache.org/viewvc/pig/branches/spark/test/org/apache/pig/test/data/GoldenFiles/tez/TEZC-Union-7-OPTOFF.gld?rev=1642132&r1=1642131&r2=1642132&view=diff ============================================================================== --- pig/branches/spark/test/org/apache/pig/test/data/GoldenFiles/tez/TEZC-Union-7-OPTOFF.gld (original) +++ pig/branches/spark/test/org/apache/pig/test/data/GoldenFiles/tez/TEZC-Union-7-OPTOFF.gld Thu Nov 27 12:49:54 2014 @@ -2,94 +2,94 @@ # There are 1 DAGs in the session #-------------------------------------------------- #-------------------------------------------------- -# TEZ DAG plan: scope-124 +# TEZ DAG plan: pig-0_scope-1 #-------------------------------------------------- -Tez vertex scope-94 -> Tez vertex scope-96, -Tez vertex scope-95 -> Tez vertex scope-96, -Tez vertex scope-96 -> Tez vertex scope-118,Tez vertex scope-108, -Tez vertex scope-108 -> Tez vertex scope-118, -Tez vertex scope-118 -> Tez vertex scope-120, -Tez vertex scope-120 +Tez vertex scope-93 -> Tez vertex scope-95, +Tez vertex scope-94 -> Tez vertex scope-95, +Tez vertex scope-95 -> Tez vertex scope-117,Tez vertex scope-107, +Tez vertex scope-107 -> Tez vertex scope-117, +Tez vertex scope-117 -> Tez vertex scope-119, +Tez vertex scope-119 -Tez vertex scope-94 +Tez vertex scope-93 # Plan on vertex -POValueOutputTez - scope-98 -> [scope-96] +POValueOutputTez - scope-97 -> [scope-95] | -|---a: New For Each(false,false)[bag] - scope-81 +|---a: New For Each(false,false)[bag] - scope-80 | | - | Cast[int] - scope-76 + | Cast[int] - scope-75 | | - | |---Project[bytearray][0] - scope-75 + | |---Project[bytearray][0] - scope-74 | | - | Cast[chararray] - scope-79 + | Cast[chararray] - scope-78 | | - | |---Project[bytearray][1] - scope-78 + | |---Project[bytearray][1] - scope-77 | - |---a: Load(file:///tmp/input:org.apache.pig.builtin.PigStorage) - scope-74 -Tez vertex scope-95 + |---a: Load(file:///tmp/input:org.apache.pig.builtin.PigStorage) - scope-73 +Tez vertex scope-94 # Plan on vertex -POValueOutputTez - scope-99 -> [scope-96] +POValueOutputTez - scope-98 -> [scope-95] | -|---c: New For Each(false,false)[bag] - scope-89 +|---c: New For Each(false,false)[bag] - scope-88 | | - | Cast[int] - scope-84 + | Cast[int] - scope-83 | | - | |---Project[bytearray][1] - scope-83 + | |---Project[bytearray][1] - scope-82 | | - | Cast[chararray] - scope-87 + | Cast[chararray] - scope-86 | | - | |---Project[bytearray][0] - scope-86 + | |---Project[bytearray][0] - scope-85 | - |---b: Load(file:///tmp/input:org.apache.pig.builtin.PigStorage) - scope-82 -Tez vertex scope-96 + |---b: Load(file:///tmp/input:org.apache.pig.builtin.PigStorage) - scope-81 +Tez vertex scope-95 # Plan on vertex -Local Rearrange[tuple]{tuple}(false) - scope-102 -> scope-108 +Local Rearrange[tuple]{tuple}(false) - scope-101 -> scope-107 | | -| Constant(DummyVal) - scope-101 +| Constant(DummyVal) - scope-100 | -|---New For Each(false,true)[tuple] - scope-107 +|---New For Each(false,true)[tuple] - scope-106 | | - | Project[int][0] - scope-91 + | Project[int][0] - scope-90 | | - | POUserFunc(org.apache.pig.impl.builtin.GetMemNumRows)[tuple] - scope-106 + | POUserFunc(org.apache.pig.impl.builtin.GetMemNumRows)[tuple] - scope-105 | | - | |---Project[tuple][*] - scope-105 + | |---Project[tuple][*] - scope-104 | - |---ReservoirSample - scope-104 + |---ReservoirSample - scope-103 | - |---d: Local Rearrange[tuple]{int}(false) - scope-100 -> scope-118 + |---d: Local Rearrange[tuple]{int}(false) - scope-99 -> scope-117 | | - | Project[int][0] - scope-91 + | Project[int][0] - scope-90 | - |---POShuffledValueInputTez - scope-97 <- [scope-94, scope-95] -Tez vertex scope-108 + |---POShuffledValueInputTez - scope-96 <- [scope-93, scope-94] +Tez vertex scope-107 # Plan on vertex -POValueOutputTez - scope-117 -> [scope-118] +POValueOutputTez - scope-116 -> [scope-117] | -|---New For Each(false)[tuple] - scope-116 +|---New For Each(false)[tuple] - scope-115 | | - | POUserFunc(org.apache.pig.backend.hadoop.executionengine.tez.FindQuantilesTez)[tuple] - scope-115 + | POUserFunc(org.apache.pig.backend.hadoop.executionengine.tez.plan.udf.FindQuantilesTez)[tuple] - scope-114 | | - | |---Project[tuple][*] - scope-114 + | |---Project[tuple][*] - scope-113 | - |---New For Each(false,false)[tuple] - scope-113 + |---New For Each(false,false)[tuple] - scope-112 | | - | Constant(-1) - scope-112 + | Constant(-1) - scope-111 | | - | Project[bag][1] - scope-110 + | Project[bag][1] - scope-109 | - |---Package(Packager)[tuple]{bytearray} - scope-109 -Tez vertex scope-118 + |---Package(Packager)[tuple]{bytearray} - scope-108 +Tez vertex scope-117 # Plan on vertex -POIdentityInOutTez - scope-119 <- scope-96 -> scope-120 +POIdentityInOutTez - scope-118 <- scope-95 -> scope-119 | | -| Project[int][0] - scope-91 -Tez vertex scope-120 +| Project[int][0] - scope-90 +Tez vertex scope-119 # Plan on vertex -d: Store(file:///tmp/output:org.apache.pig.builtin.PigStorage) - scope-93 +d: Store(file:///tmp/output:org.apache.pig.builtin.PigStorage) - scope-92 | -|---New For Each(true)[tuple] - scope-123 +|---New For Each(true)[tuple] - scope-122 | | - | Project[bag][1] - scope-122 + | Project[bag][1] - scope-121 | - |---Package(LitePackager)[tuple]{int} - scope-121 + |---Package(LitePackager)[tuple]{int} - scope-120 Modified: pig/branches/spark/test/org/apache/pig/test/data/GoldenFiles/tez/TEZC-Union-7.gld URL: http://svn.apache.org/viewvc/pig/branches/spark/test/org/apache/pig/test/data/GoldenFiles/tez/TEZC-Union-7.gld?rev=1642132&r1=1642131&r2=1642132&view=diff ============================================================================== --- pig/branches/spark/test/org/apache/pig/test/data/GoldenFiles/tez/TEZC-Union-7.gld (original) +++ pig/branches/spark/test/org/apache/pig/test/data/GoldenFiles/tez/TEZC-Union-7.gld Thu Nov 27 12:49:54 2014 @@ -2,35 +2,35 @@ # There are 1 DAGs in the session #-------------------------------------------------- #-------------------------------------------------- -# TEZ DAG plan: scope-50 +# TEZ DAG plan: pig-0_scope-0 #-------------------------------------------------- -Tez vertex scope-20 -> Tez vertex group scope-52,Tez vertex group scope-53, -Tez vertex scope-21 -> Tez vertex group scope-52,Tez vertex group scope-53, -Tez vertex group scope-53 -> Tez vertex scope-34, +Tez vertex scope-20 -> Tez vertex group scope-51,Tez vertex group scope-52, +Tez vertex scope-21 -> Tez vertex group scope-51,Tez vertex group scope-52, +Tez vertex group scope-52 -> Tez vertex scope-34, Tez vertex scope-34 -> Tez vertex scope-44, -Tez vertex group scope-52 -> Tez vertex scope-44, +Tez vertex group scope-51 -> Tez vertex scope-44, Tez vertex scope-44 -> Tez vertex scope-46, Tez vertex scope-46 Tez vertex scope-20 # Plan on vertex -Local Rearrange[tuple]{tuple}(false) - scope-55 -> scope-34 +Local Rearrange[tuple]{tuple}(false) - scope-54 -> scope-34 | | -| Constant(DummyVal) - scope-56 +| Constant(DummyVal) - scope-55 | -|---New For Each(false,true)[tuple] - scope-63 +|---New For Each(false,true)[tuple] - scope-62 | | - | Project[int][0] - scope-60 + | Project[int][0] - scope-59 | | - | POUserFunc(org.apache.pig.impl.builtin.GetMemNumRows)[tuple] - scope-62 + | POUserFunc(org.apache.pig.impl.builtin.GetMemNumRows)[tuple] - scope-61 | | - | |---Project[tuple][*] - scope-61 + | |---Project[tuple][*] - scope-60 | - |---ReservoirSample - scope-54 + |---ReservoirSample - scope-53 | - |---d: Local Rearrange[tuple]{int}(false) - scope-58 -> scope-44 + |---d: Local Rearrange[tuple]{int}(false) - scope-57 -> scope-44 | | - | Project[int][0] - scope-59 + | Project[int][0] - scope-58 | |---a: New For Each(false,false)[bag] - scope-7 | | @@ -45,23 +45,23 @@ Local Rearrange[tuple]{tuple}(false) - s |---a: Load(file:///tmp/input:org.apache.pig.builtin.PigStorage) - scope-0 Tez vertex scope-21 # Plan on vertex -Local Rearrange[tuple]{tuple}(false) - scope-65 -> scope-34 +Local Rearrange[tuple]{tuple}(false) - scope-64 -> scope-34 | | -| Constant(DummyVal) - scope-66 +| Constant(DummyVal) - scope-65 | -|---New For Each(false,true)[tuple] - scope-73 +|---New For Each(false,true)[tuple] - scope-72 | | - | Project[int][0] - scope-70 + | Project[int][0] - scope-69 | | - | POUserFunc(org.apache.pig.impl.builtin.GetMemNumRows)[tuple] - scope-72 + | POUserFunc(org.apache.pig.impl.builtin.GetMemNumRows)[tuple] - scope-71 | | - | |---Project[tuple][*] - scope-71 + | |---Project[tuple][*] - scope-70 | - |---ReservoirSample - scope-64 + |---ReservoirSample - scope-63 | - |---d: Local Rearrange[tuple]{int}(false) - scope-68 -> scope-44 + |---d: Local Rearrange[tuple]{int}(false) - scope-67 -> scope-44 | | - | Project[int][0] - scope-69 + | Project[int][0] - scope-68 | |---c: New For Each(false,false)[bag] - scope-15 | | @@ -74,7 +74,7 @@ Local Rearrange[tuple]{tuple}(false) - s | |---Project[bytearray][0] - scope-12 | |---b: Load(file:///tmp/input:org.apache.pig.builtin.PigStorage) - scope-8 -Tez vertex group scope-53 <- [scope-20, scope-21] -> scope-34 +Tez vertex group scope-52 <- [scope-20, scope-21] -> scope-34 # No plan on vertex group Tez vertex scope-34 # Plan on vertex @@ -82,7 +82,7 @@ POValueOutputTez - scope-43 -> [scope-4 | |---New For Each(false)[tuple] - scope-42 | | - | POUserFunc(org.apache.pig.backend.hadoop.executionengine.tez.FindQuantilesTez)[tuple] - scope-41 + | POUserFunc(org.apache.pig.backend.hadoop.executionengine.tez.plan.udf.FindQuantilesTez)[tuple] - scope-41 | | | |---Project[tuple][*] - scope-40 | @@ -93,11 +93,11 @@ POValueOutputTez - scope-43 -> [scope-4 | Project[bag][1] - scope-36 | |---Package(Packager)[tuple]{bytearray} - scope-35 -Tez vertex group scope-52 <- [scope-20, scope-21] -> scope-44 +Tez vertex group scope-51 <- [scope-20, scope-21] -> scope-44 # No plan on vertex group Tez vertex scope-44 # Plan on vertex -POIdentityInOutTez - scope-45 <- scope-52 -> scope-46 +POIdentityInOutTez - scope-45 <- scope-51 -> scope-46 | | | Project[int][0] - scope-17 Tez vertex scope-46 Modified: pig/branches/spark/test/org/apache/pig/test/data/GoldenFiles/tez/TEZC-Union-8-OPTOFF.gld URL: http://svn.apache.org/viewvc/pig/branches/spark/test/org/apache/pig/test/data/GoldenFiles/tez/TEZC-Union-8-OPTOFF.gld?rev=1642132&r1=1642131&r2=1642132&view=diff ============================================================================== --- pig/branches/spark/test/org/apache/pig/test/data/GoldenFiles/tez/TEZC-Union-8-OPTOFF.gld (original) +++ pig/branches/spark/test/org/apache/pig/test/data/GoldenFiles/tez/TEZC-Union-8-OPTOFF.gld Thu Nov 27 12:49:54 2014 @@ -2,78 +2,70 @@ # There are 1 DAGs in the session #-------------------------------------------------- #-------------------------------------------------- -# TEZ DAG plan: scope-88 +# TEZ DAG plan: pig-0_scope-1 #-------------------------------------------------- -Tez vertex scope-70 -> Tez vertex scope-72, -Tez vertex scope-72 -> Tez vertex scope-80, -Tez vertex scope-75 -> Tez vertex scope-77, -Tez vertex scope-77 -> Tez vertex scope-80, -Tez vertex scope-80 -> Tez vertex scope-85, -Tez vertex scope-85 - +Tez vertex scope-60 -> Tez vertex scope-62, +Tez vertex scope-62 -> Tez vertex scope-70, +Tez vertex scope-65 -> Tez vertex scope-67, +Tez vertex scope-67 -> Tez vertex scope-70, Tez vertex scope-70 + +Tez vertex scope-60 # Plan on vertex -POValueOutputTez - scope-71 -> [scope-72] +POValueOutputTez - scope-61 -> [scope-62] | -|---Limit - scope-48 +|---Limit - scope-38 | - |---a: Load(file:///tmp/input:org.apache.pig.builtin.PigStorage) - scope-47 -Tez vertex scope-72 + |---a: Load(file:///tmp/input:org.apache.pig.builtin.PigStorage) - scope-37 +Tez vertex scope-62 # Plan on vertex -POValueOutputTez - scope-82 -> [scope-80] +POValueOutputTez - scope-72 -> [scope-70] | -|---a: New For Each(false,false)[bag] - scope-56 +|---a: New For Each(false,false)[bag] - scope-46 | | - | Cast[int] - scope-51 + | Cast[int] - scope-41 | | - | |---Project[bytearray][0] - scope-50 + | |---Project[bytearray][0] - scope-40 | | - | Cast[chararray] - scope-54 + | Cast[chararray] - scope-44 | | - | |---Project[bytearray][1] - scope-53 + | |---Project[bytearray][1] - scope-43 | - |---Limit - scope-49 + |---Limit - scope-39 | - |---Limit - scope-74 + |---Limit - scope-64 | - |---POValueInputTez - scope-73 <- scope-70 -Tez vertex scope-75 + |---POValueInputTez - scope-63 <- scope-60 +Tez vertex scope-65 # Plan on vertex -POValueOutputTez - scope-76 -> [scope-77] +POValueOutputTez - scope-66 -> [scope-67] | -|---Limit - scope-58 +|---Limit - scope-48 | - |---b: Load(file:///tmp/input:org.apache.pig.builtin.PigStorage) - scope-57 -Tez vertex scope-77 + |---b: Load(file:///tmp/input:org.apache.pig.builtin.PigStorage) - scope-47 +Tez vertex scope-67 # Plan on vertex -POValueOutputTez - scope-83 -> [scope-80] +POValueOutputTez - scope-73 -> [scope-70] | -|---c: New For Each(false,false)[bag] - scope-66 +|---c: New For Each(false,false)[bag] - scope-56 | | - | Cast[int] - scope-61 + | Cast[int] - scope-51 | | - | |---Project[bytearray][1] - scope-60 + | |---Project[bytearray][1] - scope-50 | | - | Cast[chararray] - scope-64 + | Cast[chararray] - scope-54 | | - | |---Project[bytearray][0] - scope-63 + | |---Project[bytearray][0] - scope-53 | - |---Limit - scope-59 + |---Limit - scope-49 | - |---Limit - scope-79 + |---Limit - scope-69 | - |---POValueInputTez - scope-78 <- scope-75 -Tez vertex scope-80 -# Plan on vertex -POValueOutputTez - scope-84 -> [scope-85] -| -|---d: Limit - scope-68 - | - |---POShuffledValueInputTez - scope-81 <- [scope-77, scope-72] -Tez vertex scope-85 + |---POValueInputTez - scope-68 <- scope-65 +Tez vertex scope-70 # Plan on vertex -d: Store(file:///tmp/output:org.apache.pig.builtin.PigStorage) - scope-69 +d: Store(file:///tmp/output:org.apache.pig.builtin.PigStorage) - scope-59 | -|---d: Limit - scope-87 +|---d: Limit - scope-58 | - |---POValueInputTez - scope-86 <- scope-80 + |---POShuffledValueInputTez - scope-71 <- [scope-67, scope-62] Modified: pig/branches/spark/test/org/apache/pig/test/data/GoldenFiles/tez/TEZC-Union-8.gld URL: http://svn.apache.org/viewvc/pig/branches/spark/test/org/apache/pig/test/data/GoldenFiles/tez/TEZC-Union-8.gld?rev=1642132&r1=1642131&r2=1642132&view=diff ============================================================================== --- pig/branches/spark/test/org/apache/pig/test/data/GoldenFiles/tez/TEZC-Union-8.gld (original) +++ pig/branches/spark/test/org/apache/pig/test/data/GoldenFiles/tez/TEZC-Union-8.gld Thu Nov 27 12:49:54 2014 @@ -2,14 +2,13 @@ # There are 1 DAGs in the session #-------------------------------------------------- #-------------------------------------------------- -# TEZ DAG plan: scope-41 +# TEZ DAG plan: pig-0_scope-0 #-------------------------------------------------- Tez vertex scope-23 -> Tez vertex scope-25, -Tez vertex scope-25 -> Tez vertex group scope-42, +Tez vertex scope-25 -> Tez vertex scope-33, Tez vertex scope-28 -> Tez vertex scope-30, -Tez vertex scope-30 -> Tez vertex group scope-42, -Tez vertex group scope-42 -> Tez vertex scope-38, -Tez vertex scope-38 +Tez vertex scope-30 -> Tez vertex scope-33, +Tez vertex scope-33 Tez vertex scope-23 # Plan on vertex @@ -20,25 +19,23 @@ POValueOutputTez - scope-24 -> [scope-2 |---a: Load(file:///tmp/input:org.apache.pig.builtin.PigStorage) - scope-0 Tez vertex scope-25 # Plan on vertex -POValueOutputTez - scope-43 -> [scope-38] +POValueOutputTez - scope-35 -> [scope-33] | -|---d: Limit - scope-44 +|---a: New For Each(false,false)[bag] - scope-9 + | | + | Cast[int] - scope-4 + | | + | |---Project[bytearray][0] - scope-3 + | | + | Cast[chararray] - scope-7 + | | + | |---Project[bytearray][1] - scope-6 | - |---a: New For Each(false,false)[bag] - scope-9 - | | - | Cast[int] - scope-4 - | | - | |---Project[bytearray][0] - scope-3 - | | - | Cast[chararray] - scope-7 - | | - | |---Project[bytearray][1] - scope-6 + |---Limit - scope-2 | - |---Limit - scope-2 + |---Limit - scope-27 | - |---Limit - scope-27 - | - |---POValueInputTez - scope-26 <- scope-23 + |---POValueInputTez - scope-26 <- scope-23 Tez vertex scope-28 # Plan on vertex POValueOutputTez - scope-29 -> [scope-30] @@ -48,31 +45,27 @@ POValueOutputTez - scope-29 -> [scope-3 |---b: Load(file:///tmp/input:org.apache.pig.builtin.PigStorage) - scope-10 Tez vertex scope-30 # Plan on vertex -POValueOutputTez - scope-45 -> [scope-38] +POValueOutputTez - scope-36 -> [scope-33] | -|---d: Limit - scope-46 +|---c: New For Each(false,false)[bag] - scope-19 + | | + | Cast[int] - scope-14 + | | + | |---Project[bytearray][1] - scope-13 + | | + | Cast[chararray] - scope-17 + | | + | |---Project[bytearray][0] - scope-16 | - |---c: New For Each(false,false)[bag] - scope-19 - | | - | Cast[int] - scope-14 - | | - | |---Project[bytearray][1] - scope-13 - | | - | Cast[chararray] - scope-17 - | | - | |---Project[bytearray][0] - scope-16 + |---Limit - scope-12 | - |---Limit - scope-12 + |---Limit - scope-32 | - |---Limit - scope-32 - | - |---POValueInputTez - scope-31 <- scope-28 -Tez vertex group scope-42 <- [scope-25, scope-30] -> scope-38 -# No plan on vertex group -Tez vertex scope-38 + |---POValueInputTez - scope-31 <- scope-28 +Tez vertex scope-33 # Plan on vertex d: Store(file:///tmp/output:org.apache.pig.builtin.PigStorage) - scope-22 | -|---d: Limit - scope-40 +|---d: Limit - scope-21 | - |---POValueInputTez - scope-39 <- scope-42 + |---POShuffledValueInputTez - scope-34 <- [scope-30, scope-25]
