blob: b4d69343b10959dbdadc05f423901287297e77c7 [file] [log] [blame]
Yingyi Buae555ba2016-03-09 21:29:32 -08001-- DISTRIBUTE_RESULT |PARTITIONED|
2 -- ONE_TO_ONE_EXCHANGE |PARTITIONED|
3 -- STREAM_PROJECT |PARTITIONED|
4 -- ASSIGN |PARTITIONED|
5 -- STREAM_PROJECT |PARTITIONED|
6 -- ONE_TO_ONE_EXCHANGE |PARTITIONED|
7 -- PRE_CLUSTERED_GROUP_BY[$$12] |PARTITIONED|
8 {
9 -- AGGREGATE |LOCAL|
10 -- STREAM_SELECT |LOCAL|
11 -- NESTED_TUPLE_SOURCE |LOCAL|
12 }
13 -- ONE_TO_ONE_EXCHANGE |PARTITIONED|
14 -- STABLE_SORT [$$12(ASC)] |PARTITIONED|
15 -- HASH_PARTITION_EXCHANGE [$$12] |PARTITIONED|
16 -- STREAM_PROJECT |PARTITIONED|
17 -- ONE_TO_ONE_EXCHANGE |PARTITIONED|
18 -- HYBRID_HASH_JOIN [$$1][$$11] |PARTITIONED|
19 -- HASH_PARTITION_EXCHANGE [$$1] |PARTITIONED|
20 -- ASSIGN |UNPARTITIONED|
21 -- STREAM_PROJECT |UNPARTITIONED|
22 -- UNNEST |UNPARTITIONED|
23 -- ASSIGN |UNPARTITIONED|
24 -- EMPTY_TUPLE_SOURCE |UNPARTITIONED|
25 -- HASH_PARTITION_EXCHANGE [$$11] |PARTITIONED|
26 -- STREAM_PROJECT |PARTITIONED|
27 -- ASSIGN |PARTITIONED|
28 -- ONE_TO_ONE_EXCHANGE |PARTITIONED|
29 -- DATASOURCE_SCAN |PARTITIONED|
30 -- ONE_TO_ONE_EXCHANGE |PARTITIONED|
31 -- EMPTY_TUPLE_SOURCE |PARTITIONED|