blob: 76cd11fc46fdd358f871d92f59494f6ea829451c [file] [log] [blame]
Yingyi Bu5170fb22017-08-17 12:50:55 -07001-- DISTRIBUTE_RESULT |PARTITIONED|
2 -- ONE_TO_ONE_EXCHANGE |PARTITIONED|
3 -- STREAM_PROJECT |PARTITIONED|
4 -- ASSIGN |PARTITIONED|
5 -- SORT_MERGE_EXCHANGE [$$l_returnflag(ASC), $$l_linestatus(ASC) ] |PARTITIONED|
Dmitry Lychaginef1719e2017-12-15 08:33:07 -08006 -- PRE_CLUSTERED_GROUP_BY[$$120, $$121] |PARTITIONED|
Yingyi Bu5170fb22017-08-17 12:50:55 -07007 {
8 -- AGGREGATE |LOCAL|
9 -- NESTED_TUPLE_SOURCE |LOCAL|
10 }
11 {
12 -- AGGREGATE |LOCAL|
13 -- NESTED_TUPLE_SOURCE |LOCAL|
14 }
15 -- ONE_TO_ONE_EXCHANGE |PARTITIONED|
Dmitry Lychaginef1719e2017-12-15 08:33:07 -080016 -- STABLE_SORT [$$120(ASC), $$121(ASC)] |PARTITIONED|
17 -- HASH_PARTITION_EXCHANGE [$$120, $$121] |PARTITIONED|
18 -- PRE_CLUSTERED_GROUP_BY[$$108, $$109] |PARTITIONED|
Yingyi Bu5170fb22017-08-17 12:50:55 -070019 {
20 -- AGGREGATE |LOCAL|
21 -- STREAM_SELECT |LOCAL|
22 -- NESTED_TUPLE_SOURCE |LOCAL|
23 }
24 {
25 -- AGGREGATE |LOCAL|
26 -- STREAM_SELECT |LOCAL|
27 -- NESTED_TUPLE_SOURCE |LOCAL|
28 }
29 -- ONE_TO_ONE_EXCHANGE |PARTITIONED|
Dmitry Lychaginef1719e2017-12-15 08:33:07 -080030 -- STABLE_SORT [$$108(ASC), $$109(ASC)] |PARTITIONED|
Yingyi Bu5170fb22017-08-17 12:50:55 -070031 -- ONE_TO_ONE_EXCHANGE |PARTITIONED|
32 -- ASSIGN |PARTITIONED|
33 -- STREAM_PROJECT |PARTITIONED|
Yingyi Bu342bd342017-09-06 13:17:02 -070034 -- ONE_TO_ONE_EXCHANGE |PARTITIONED|
35 -- DATASOURCE_SCAN |PARTITIONED|
Yingyi Bu5170fb22017-08-17 12:50:55 -070036 -- ONE_TO_ONE_EXCHANGE |PARTITIONED|
Yingyi Bu342bd342017-09-06 13:17:02 -070037 -- EMPTY_TUPLE_SOURCE |PARTITIONED|