blob: 44f21accef96e78db6f12545317ff8ae22409ea0 [file] [log] [blame]
Young-Seokbe353dd2014-05-22 20:30:45 -07001-- DISTRIBUTE_RESULT |PARTITIONED|
2 -- ONE_TO_ONE_EXCHANGE |PARTITIONED|
3 -- STREAM_PROJECT |PARTITIONED|
4 -- ASSIGN |PARTITIONED|
Yingyi Bu947fc3c2016-01-27 20:14:47 -08005 -- ONE_TO_ONE_EXCHANGE |PARTITIONED|
6 -- PRE_CLUSTERED_GROUP_BY[$$21] |PARTITIONED|
7 {
8 -- AGGREGATE |LOCAL|
9 -- STREAM_SELECT |LOCAL|
10 -- NESTED_TUPLE_SOURCE |LOCAL|
11 }
12 -- ONE_TO_ONE_EXCHANGE |PARTITIONED|
13 -- STABLE_SORT [$$21(ASC)] |PARTITIONED|
14 -- HASH_PARTITION_EXCHANGE [$$21] |PARTITIONED|
15 -- STREAM_PROJECT |PARTITIONED|
16 -- STREAM_SELECT |PARTITIONED|
17 -- STREAM_PROJECT |PARTITIONED|
18 -- ONE_TO_ONE_EXCHANGE |PARTITIONED|
19 -- BTREE_SEARCH |PARTITIONED|
20 -- ONE_TO_ONE_EXCHANGE |PARTITIONED|
21 -- STABLE_SORT [$$36(ASC)] |PARTITIONED|
22 -- ONE_TO_ONE_EXCHANGE |PARTITIONED|
23 -- STREAM_PROJECT |PARTITIONED|
24 -- ONE_TO_ONE_EXCHANGE |PARTITIONED|
25 -- RTREE_SEARCH |PARTITIONED|
26 -- BROADCAST_EXCHANGE |PARTITIONED|
27 -- ASSIGN |PARTITIONED|
28 -- STREAM_PROJECT |PARTITIONED|
29 -- ASSIGN |PARTITIONED|
30 -- STREAM_PROJECT |PARTITIONED|
31 -- STREAM_SELECT |PARTITIONED|
32 -- ASSIGN |PARTITIONED|
33 -- ONE_TO_ONE_EXCHANGE |PARTITIONED|
34 -- DATASOURCE_SCAN |PARTITIONED|
35 -- ONE_TO_ONE_EXCHANGE |PARTITIONED|
36 -- EMPTY_TUPLE_SOURCE |PARTITIONED|