#-------------------------------------------------- # There are 1 DAGs in the session #-------------------------------------------------- #-------------------------------------------------- # TEZ DAG plan: scope-51 #-------------------------------------------------- Tez vertex scope-23 -> Tez vertex scope-24, Tez vertex scope-24 -> Tez vertex scope-41,Tez vertex scope-31, Tez vertex scope-31 -> Tez vertex scope-41, Tez vertex scope-41 -> Tez vertex scope-43, Tez vertex scope-43 -> Tez vertex scope-49,Tez vertex scope-47, Tez vertex scope-47 -> Tez vertex scope-49, Tez vertex scope-49 Tez vertex scope-23 # Plan on vertex b: Local Rearrange[tuple]{int}(false) - scope-10 -> scope-24 | | | Project[int][0] - scope-11 | |---a: New For Each(false,false)[bag] - scope-7 | | | Cast[int] - scope-2 | | | |---Project[bytearray][0] - scope-1 | | | Cast[int] - scope-5 | | | |---Project[bytearray][1] - scope-4 | |---a: Load(file:///tmp/input1:org.apache.pig.builtin.PigStorage) - scope-0 Tez vertex scope-24 # Plan on vertex Local Rearrange[tuple]{tuple}(false) - scope-27 -> scope-31 | | | Constant(DummyVal) - scope-26 | |---ReservoirSample - scope-30 | |---New For Each(false)[tuple] - scope-29 | | | Project[int][0] - scope-28 | |---b: Local Rearrange[tuple]{int}(false) - scope-25 -> scope-41 | | | Project[int][0] - scope-15 | |---New For Each(true,false)[tuple] - scope-14 | | | Project[int][0] - scope-12 | | | Project[bag][1] - scope-13 | |---b: Package(Packager)[tuple]{int} - scope-9 Tez vertex scope-31 # Plan on vertex POValueOutputTez - scope-40 -> [scope-41] | |---New For Each(false)[tuple] - scope-39 | | | POUserFunc(org.apache.pig.impl.builtin.FindQuantiles)[tuple] - scope-38 | | | |---Project[tuple][*] - scope-37 | |---New For Each(false,false)[tuple] - scope-36 | | | Constant(1) - scope-35 | | | Project[bag][1] - scope-33 | |---Package(Packager)[tuple]{bytearray} - scope-32 Tez vertex scope-41 # Plan on vertex POIdentityInOutTez - scope-42 <- scope-24 -> scope-43 | | | Project[int][0] - scope-15 Tez vertex scope-43 # Plan on vertex POCounterTez - scope-17 -> scope-49,scope-47 | | | Project[int][0] - scope-15 | |---New For Each(true)[tuple] - scope-46 | | | Project[bag][1] - scope-45 | |---Package(LitePackager)[tuple]{int} - scope-44 Tez vertex scope-47 # Plan on vertex PORankStatsTez - scope-48 <- scope-43 -> scope-49 Tez vertex scope-49 # Plan on vertex b: Store(file:///tmp/output/d:org.apache.pig.builtin.PigStorage) - scope-22 | |---New For Each(false,true)[tuple] - scope-21 | | | Project[long][0] - scope-19 | | | Project[bag][2] - scope-20 | |---PORankTez - scope-18 <- scope-43,scope-47 | | | Project[int][0] - scope-15