#-------------------------------------------------- # There are 1 DAGs in the session #-------------------------------------------------- #-------------------------------------------------- # TEZ DAG plan: scope-58 #-------------------------------------------------- Tez vertex scope-56 -> Tez vertex scope-57, Tez vertex scope-57 Tez vertex scope-56 # Plan on vertex b: Local Rearrange[tuple]{int}(false) - scope-43 -> scope-57 | | | Project[int][0] - scope-44 | |---a: New For Each(false,false,false)[bag] - scope-40 | | | Cast[int] - scope-32 | | | |---Project[bytearray][0] - scope-31 | | | Cast[int] - scope-35 | | | |---Project[bytearray][1] - scope-34 | | | Cast[int] - scope-38 | | | |---Project[bytearray][2] - scope-37 | |---a: Load(file:///tmp/input:PigStorage(',')) - scope-30 Tez vertex scope-57 # Plan on vertex c: Store(file:///tmp/output:org.apache.pig.builtin.PigStorage) - scope-55 | |---c: New For Each(false,false)[bag] - scope-54 | | | Project[int][0] - scope-45 | | | RelationToExpressionProject[bag][*] - scope-47 | | | |---f: POSort[bag]() - scope-53 | | | | | Project[int][0] - scope-52 | | | |---e: POSort[bag]() - scope-51 | | | | | Project[int][1] - scope-50 | | | |---d: Limit - scope-49 | | | |---Project[bag][1] - scope-48 | |---b: Package(Packager)[tuple]{int} - scope-42