blob: 28625aa57b0d8e7fe5a394f7ecec3fa49d8327d7 [file] [log] [blame]
buyingyia9a02022015-01-15 10:40:15 -08001-- DISTRIBUTE_RESULT |PARTITIONED|
2 -- ONE_TO_ONE_EXCHANGE |PARTITIONED|
3 -- STREAM_PROJECT |PARTITIONED|
4 -- ASSIGN |PARTITIONED|
5 -- SORT_MERGE_EXCHANGE [$$7(ASC) ] |PARTITIONED|
Yingyi Bu1e7760c2016-02-22 16:25:42 -08006 -- PRE_CLUSTERED_GROUP_BY[$$86] |PARTITIONED|
buyingyia9a02022015-01-15 10:40:15 -08007 {
8 -- AGGREGATE |LOCAL|
9 -- NESTED_TUPLE_SOURCE |LOCAL|
10 }
Yingyi Bu1e7760c2016-02-22 16:25:42 -080011 -- HASH_PARTITION_MERGE_EXCHANGE MERGE:[$$86(ASC)] HASH:[$$86] |PARTITIONED|
buyingyia9a02022015-01-15 10:40:15 -080012 -- SORT_GROUP_BY[$$59] |PARTITIONED|
13 {
14 -- AGGREGATE |LOCAL|
15 -- NESTED_TUPLE_SOURCE |LOCAL|
16 }
17 -- ONE_TO_ONE_EXCHANGE |PARTITIONED|
18 -- STREAM_PROJECT |PARTITIONED|
Yingyi Bu947fc3c2016-01-27 20:14:47 -080019 -- ASSIGN |PARTITIONED|
buyingyia9a02022015-01-15 10:40:15 -080020 -- STREAM_PROJECT |PARTITIONED|
Yingyi Bu947fc3c2016-01-27 20:14:47 -080021 -- STREAM_SELECT |PARTITIONED|
22 -- STREAM_PROJECT |PARTITIONED|
23 -- ONE_TO_ONE_EXCHANGE |PARTITIONED|
Yingyi Bu1e7760c2016-02-22 16:25:42 -080024 -- SORT_GROUP_BY[$$83] |PARTITIONED|
buyingyia9a02022015-01-15 10:40:15 -080025 {
26 -- AGGREGATE |LOCAL|
Yingyi Bu947fc3c2016-01-27 20:14:47 -080027 -- NESTED_TUPLE_SOURCE |LOCAL|
buyingyia9a02022015-01-15 10:40:15 -080028 }
Yingyi Bu1e7760c2016-02-22 16:25:42 -080029 -- HASH_PARTITION_EXCHANGE [$$83] |PARTITIONED|
30 -- STREAM_PROJECT |PARTITIONED|
buyingyia9a02022015-01-15 10:40:15 -080031 -- ONE_TO_ONE_EXCHANGE |PARTITIONED|
Yingyi Bu1e7760c2016-02-22 16:25:42 -080032 -- PRE_CLUSTERED_GROUP_BY[$$65, $$11, $$62] |PARTITIONED|
33 {
34 -- AGGREGATE |LOCAL|
35 -- STREAM_SELECT |LOCAL|
36 -- NESTED_TUPLE_SOURCE |LOCAL|
37 }
buyingyia9a02022015-01-15 10:40:15 -080038 -- ONE_TO_ONE_EXCHANGE |PARTITIONED|
Yingyi Bu1e7760c2016-02-22 16:25:42 -080039 -- STABLE_SORT [$$65(ASC), $$65(ASC), $$62(ASC)] |PARTITIONED|
Yingyi Bu947fc3c2016-01-27 20:14:47 -080040 -- ONE_TO_ONE_EXCHANGE |PARTITIONED|
Yingyi Bu1e7760c2016-02-22 16:25:42 -080041 -- STABLE_SORT [$$65(ASC), $$65(ASC), $$62(ASC)] |PARTITIONED|
42 -- ONE_TO_ONE_EXCHANGE |PARTITIONED|
43 -- STREAM_PROJECT |PARTITIONED|
44 -- ONE_TO_ONE_EXCHANGE |PARTITIONED|
45 -- HYBRID_HASH_JOIN [$$68][$$69] |PARTITIONED|
46 -- HASH_PARTITION_EXCHANGE [$$68] |PARTITIONED|
47 -- ASSIGN |PARTITIONED|
48 -- ASSIGN |PARTITIONED|
49 -- ONE_TO_ONE_EXCHANGE |PARTITIONED|
50 -- HYBRID_HASH_JOIN [$$65][$$11] |PARTITIONED|
51 -- HASH_PARTITION_EXCHANGE [$$65] |PARTITIONED|
52 -- UNNEST |UNPARTITIONED|
53 -- EMPTY_TUPLE_SOURCE |UNPARTITIONED|
54 -- HASH_PARTITION_EXCHANGE [$$11] |PARTITIONED|
Yingyi Bu947fc3c2016-01-27 20:14:47 -080055 -- ASSIGN |PARTITIONED|
Yingyi Bu1e7760c2016-02-22 16:25:42 -080056 -- STREAM_PROJECT |PARTITIONED|
57 -- ASSIGN |PARTITIONED|
Yingyi Bu947fc3c2016-01-27 20:14:47 -080058 -- ONE_TO_ONE_EXCHANGE |PARTITIONED|
Yingyi Bu1e7760c2016-02-22 16:25:42 -080059 -- DATASOURCE_SCAN |PARTITIONED|
60 -- ONE_TO_ONE_EXCHANGE |PARTITIONED|
61 -- EMPTY_TUPLE_SOURCE |PARTITIONED|
62 -- HASH_PARTITION_EXCHANGE [$$69] |PARTITIONED|
63 -- ASSIGN |PARTITIONED|
64 -- STREAM_PROJECT |PARTITIONED|
65 -- ONE_TO_ONE_EXCHANGE |PARTITIONED|
66 -- DATASOURCE_SCAN |PARTITIONED|
67 -- ONE_TO_ONE_EXCHANGE |PARTITIONED|
68 -- EMPTY_TUPLE_SOURCE |PARTITIONED|