blob: 2f71cd5dde2b3c6504fc1f5cd624282f953b93fb [file] [log] [blame]
#--------------------------------------------------
# There are 1 DAGs in the session
#--------------------------------------------------
#--------------------------------------------------
# TEZ DAG plan: pig-0_scope-0
#--------------------------------------------------
Tez vertex scope-79 -> Tez vertex scope-81,Tez vertex scope-98,Tez vertex scope-122,Tez vertex scope-124,
Tez vertex scope-98 -> Tez vertex scope-104,
Tez vertex scope-122 -> Tez vertex scope-81,
Tez vertex scope-81 -> Tez vertex scope-104,Tez vertex scope-126,
Tez vertex scope-104
Tez vertex scope-124 -> Tez vertex scope-126,
Tez vertex scope-126
Tez vertex scope-79
# Plan on vertex
POValueOutputTez - scope-80 -> [scope-122, scope-124, scope-81, scope-98]
|
|---a: New For Each(false,false)[bag] - scope-7
| |
| Cast[int] - scope-2
| |
| |---Project[bytearray][0] - scope-1
| |
| Cast[chararray] - scope-5
| |
| |---Project[bytearray][1] - scope-4
|
|---a: Load(file:///tmp/input:org.apache.pig.builtin.PigStorage) - scope-0
Tez vertex scope-98
# Plan on vertex
POValueOutputTez - scope-106 -> [scope-104]
|
|---POValueInputTez - scope-99 <- scope-79
Tez vertex scope-122
# Plan on vertex
Local Rearrange[tuple]{int}(false) - scope-67 -> scope-81
| |
| Project[int][0] - scope-63
|
|---POValueInputTez - scope-123 <- scope-79
Tez vertex scope-81
# Plan on vertex
1-1: Split - scope-133
| |
| u3: Store(file:///tmp/pigoutput/u3:org.apache.pig.builtin.PigStorage) - scope-135 -> scope-57
| |
| |---e: Filter[bag] - scope-43
| | |
| | Not[boolean] - scope-55
| | |
| | |---Or[boolean] - scope-54
| | |
| | |---Or[boolean] - scope-50
| | | |
| | | |---Greater Than[boolean] - scope-46
| | | | |
| | | | |---Project[int][0] - scope-44
| | | | |
| | | | |---Constant(5) - scope-45
| | | |
| | | |---Equal To[boolean] - scope-49
| | | |
| | | |---Project[int][0] - scope-47
| | | |
| | | |---Constant(7) - scope-48
| | |
| | |---Equal To[boolean] - scope-53
| | |
| | |---Project[int][0] - scope-51
| | |
| | |---Constant(8) - scope-52
| |
| d: Split - scope-132
| | |
| | u3: Store(file:///tmp/pigoutput/u3:org.apache.pig.builtin.PigStorage) - scope-134 -> scope-57
| | |
| | POValueOutputTez - scope-128 -> [scope-126]
| | |
| | |---j1: New For Each(false,false)[bag] - scope-74
| | | |
| | | Project[int][0] - scope-70
| | | |
| | | Project[chararray][1] - scope-72
| | |
| | |---j1: FRJoin[tuple] - scope-64 <- scope-122
| | | |
| | | Project[int][0] - scope-62
| | | |
| | | Project[int][0] - scope-63
| |
| |---d: Filter[bag] - scope-36
| | |
| | Equal To[boolean] - scope-39
| | |
| | |---Project[int][0] - scope-37
| | |
| | |---Constant(8) - scope-38
| |
| b: Split - scope-130
| | |
| | u1: Store(file:///tmp/pigoutput/u1:org.apache.pig.builtin.PigStorage) - scope-136 -> scope-27
| | |
| | POValueOutputTez - scope-107 -> [scope-104]
| |
| |---b: Filter[bag] - scope-12
| | |
| | Greater Than[boolean] - scope-15
| | |
| | |---Project[int][0] - scope-13
| | |
| | |---Constant(5) - scope-14
| |
| c: Split - scope-131
| | |
| | u1: Store(file:///tmp/pigoutput/u1:org.apache.pig.builtin.PigStorage) - scope-137 -> scope-27
| | |
| | POValueOutputTez - scope-108 -> [scope-104]
| |
| |---c: Filter[bag] - scope-19
| | |
| | Equal To[boolean] - scope-22
| | |
| | |---Project[int][0] - scope-20
| | |
| | |---Constant(7) - scope-21
|
|---POValueInputTez - scope-82 <- scope-79
Tez vertex scope-104
# Plan on vertex
u2: Store(file:///tmp/pigoutput/u2:org.apache.pig.builtin.PigStorage) - scope-35
|
|---POShuffledValueInputTez - scope-105 <- [scope-81, scope-98]
Tez vertex scope-124
# Plan on vertex
POValueOutputTez - scope-129 -> [scope-126]
|
|---POValueInputTez - scope-125 <- scope-79
Tez vertex scope-126
# Plan on vertex
u4: Store(file:///tmp/pigoutput/u4:org.apache.pig.builtin.PigStorage) - scope-78
|
|---POShuffledValueInputTez - scope-127 <- [scope-124, scope-81]