blob: 7ea82a121395e8c8af9e95841d90030b7b935e37 [file] [log] [blame]
Taewoo Kim753576f2017-02-28 17:52:55 -08001-- DISTRIBUTE_RESULT |PARTITIONED|
2 -- ONE_TO_ONE_EXCHANGE |PARTITIONED|
3 -- STREAM_PROJECT |PARTITIONED|
4 -- ASSIGN |PARTITIONED|
Yingyi Bu049d5412017-05-09 13:02:03 -07005 -- SORT_MERGE_EXCHANGE [$$l_returnflag(ASC), $$l_linestatus(ASC) ] |PARTITIONED|
Xikui Wang96fd4022017-04-10 14:23:31 -07006 -- SORT_GROUP_BY[$$98, $$99] |PARTITIONED|
Taewoo Kim753576f2017-02-28 17:52:55 -08007 {
8 -- AGGREGATE |LOCAL|
9 -- NESTED_TUPLE_SOURCE |LOCAL|
10 }
Xikui Wang96fd4022017-04-10 14:23:31 -070011 -- HASH_PARTITION_EXCHANGE [$$98, $$99] |PARTITIONED|
12 -- SORT_GROUP_BY[$$66, $$67] |PARTITIONED|
Taewoo Kim753576f2017-02-28 17:52:55 -080013 {
14 -- AGGREGATE |LOCAL|
15 -- NESTED_TUPLE_SOURCE |LOCAL|
16 }
17 -- ONE_TO_ONE_EXCHANGE |PARTITIONED|
18 -- STREAM_PROJECT |PARTITIONED|
19 -- STREAM_SELECT |PARTITIONED|
20 -- ASSIGN |PARTITIONED|
21 -- STREAM_PROJECT |PARTITIONED|
22 -- ONE_TO_ONE_EXCHANGE |PARTITIONED|
23 -- DATASOURCE_SCAN |PARTITIONED|
24 -- ONE_TO_ONE_EXCHANGE |PARTITIONED|
25 -- EMPTY_TUPLE_SOURCE |PARTITIONED|