You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@pig.apache.org by pr...@apache.org on 2014/11/27 13:50:02 UTC
svn commit: r1642132 [13/14] - in /pig/branches/spark: ./ bin/
contrib/piggybank/java/src/main/java/org/apache/pig/piggybank/evaluation/
contrib/piggybank/java/src/main/java/org/apache/pig/piggybank/evaluation/datetime/convert/
contrib/piggybank/java/s...
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]