blob: 0cf222a6d93c77b666686bb5b08bb424928ea3f3 [file] [log] [blame]
#--------------------------------------------------
# There are 1 DAGs in the session
#--------------------------------------------------
#--------------------------------------------------
# TEZ DAG plan: pig-0_scope-1
#--------------------------------------------------
Tez vertex scope-125 -> Tez vertex scope-127,Tez vertex scope-130,
Tez vertex scope-127 -> Tez vertex scope-129,
Tez vertex scope-129
Tez vertex scope-130 -> Tez vertex scope-132,
Tez vertex scope-132
Tez vertex scope-125
# Plan on vertex
POValueOutputTez - scope-126 -> [scope-127, scope-130]
|
|---a: New For Each(false,false)[bag] - scope-94
| |
| Cast[int] - scope-89
| |
| |---Project[bytearray][0] - scope-88
| |
| Cast[int] - scope-92
| |
| |---Project[bytearray][1] - scope-91
|
|---a: Load(file:///tmp/input:org.apache.pig.builtin.PigStorage) - scope-87
Tez vertex scope-127
# Plan on vertex
b: Local Rearrange[tuple]{int}(false) - scope-145 -> scope-129
| |
| Project[int][0] - scope-147
|
|---b: New For Each(false,false)[bag] - scope-133
| |
| Project[int][0] - scope-134
| |
| POUserFunc(org.apache.pig.builtin.COUNT$Initial)[tuple] - scope-135
| |
| |---Project[bag][0] - scope-136
| |
| |---Project[bag][1] - scope-137
|
|---Pre Combiner Local Rearrange[tuple]{Unknown} - scope-148
|
|---POValueInputTez - scope-128 <- scope-125
Tez vertex scope-129
# Combine plan on edge <scope-127>
b: Local Rearrange[tuple]{int}(false) - scope-149 -> scope-129
| |
| Project[int][0] - scope-151
|
|---b: New For Each(false,false)[bag] - scope-138
| |
| Project[int][0] - scope-139
| |
| POUserFunc(org.apache.pig.builtin.COUNT$Intermediate)[tuple] - scope-140
| |
| |---Project[bag][1] - scope-141
|
|---b: Package(CombinerPackager)[tuple]{int} - scope-144
# Plan on vertex
b: Store(file:///tmp/pigoutput/b:org.apache.pig.builtin.PigStorage) - scope-109
|
|---b: New For Each(false,false)[bag] - scope-108
| |
| Project[int][0] - scope-102
| |
| POUserFunc(org.apache.pig.builtin.COUNT$Final)[long] - scope-106
| |
| |---Project[bag][1] - scope-142
|
|---b: Package(CombinerPackager)[tuple]{int} - scope-99
Tez vertex scope-130
# Plan on vertex
c: Local Rearrange[tuple]{tuple}(false) - scope-164 -> scope-132
| |
| Project[tuple][0] - scope-167
|
|---c: New For Each(false,false)[bag] - scope-152
| |
| Project[tuple][0] - scope-153
| |
| POUserFunc(org.apache.pig.builtin.COUNT$Initial)[tuple] - scope-154
| |
| |---Project[bag][1] - scope-155
| |
| |---Project[bag][1] - scope-156
|
|---Pre Combiner Local Rearrange[tuple]{Unknown} - scope-168
|
|---POValueInputTez - scope-131 <- scope-125
Tez vertex scope-132
# Combine plan on edge <scope-130>
c: Local Rearrange[tuple]{tuple}(false) - scope-169 -> scope-132
| |
| Project[tuple][0] - scope-172
|
|---c: New For Each(false,false)[bag] - scope-157
| |
| Project[tuple][0] - scope-158
| |
| POUserFunc(org.apache.pig.builtin.COUNT$Intermediate)[tuple] - scope-159
| |
| |---Project[bag][1] - scope-160
|
|---c: Package(CombinerPackager)[tuple]{tuple} - scope-163
# Plan on vertex
c: Store(file:///tmp/pigoutput/c:org.apache.pig.builtin.PigStorage) - scope-124
|
|---c: New For Each(false,false)[bag] - scope-123
| |
| Project[tuple][0] - scope-117
| |
| POUserFunc(org.apache.pig.builtin.COUNT$Final)[long] - scope-121
| |
| |---Project[bag][1] - scope-161
|
|---c: Package(CombinerPackager)[tuple]{tuple} - scope-113