blob: ac2c294778c3ff087a4d94f4e6024b227b9158f3 [file] [log] [blame]
buyingyibd904112014-10-27 18:41:43 -07001-- DISTRIBUTE_RESULT |PARTITIONED|
2 -- ONE_TO_ONE_EXCHANGE |PARTITIONED|
3 -- STREAM_PROJECT |PARTITIONED|
4 -- ASSIGN |PARTITIONED|
5 -- ONE_TO_ONE_EXCHANGE |PARTITIONED|
buyingyia9a02022015-01-15 10:40:15 -08006 -- PRE_CLUSTERED_GROUP_BY[$$7] |PARTITIONED|
buyingyibd904112014-10-27 18:41:43 -07007 {
8 -- AGGREGATE |LOCAL|
9 -- STREAM_LIMIT |LOCAL|
buyingyia9a02022015-01-15 10:40:15 -080010 -- IN_MEMORY_STABLE_SORT [$$62(DESC)] |LOCAL|
buyingyibd904112014-10-27 18:41:43 -070011 -- NESTED_TUPLE_SOURCE |LOCAL|
12 }
13 -- ONE_TO_ONE_EXCHANGE |PARTITIONED|
buyingyia9a02022015-01-15 10:40:15 -080014 -- STABLE_SORT [$$7(ASC)] |PARTITIONED|
15 -- HASH_PARTITION_EXCHANGE [$$7] |PARTITIONED|
16 -- PRE_CLUSTERED_GROUP_BY[$$69, $$70] |PARTITIONED|
17 {
18 -- AGGREGATE |LOCAL|
19 -- NESTED_TUPLE_SOURCE |LOCAL|
20 }
21 -- HASH_PARTITION_MERGE_EXCHANGE MERGE:[$$69(ASC), $$70(ASC)] HASH:[$$69, $$70] |PARTITIONED|
22 -- SORT_GROUP_BY[$$50, $$54] |PARTITIONED|
23 {
24 -- AGGREGATE |LOCAL|
25 -- NESTED_TUPLE_SOURCE |LOCAL|
26 }
27 -- ONE_TO_ONE_EXCHANGE |PARTITIONED|
28 -- STREAM_PROJECT |PARTITIONED|
29 -- ONE_TO_ONE_EXCHANGE |PARTITIONED|
30 -- HYBRID_HASH_JOIN [$$56][$$60] |PARTITIONED|
31 -- HASH_PARTITION_EXCHANGE [$$56] |PARTITIONED|
32 -- STREAM_PROJECT |PARTITIONED|
33 -- ONE_TO_ONE_EXCHANGE |PARTITIONED|
34 -- HYBRID_HASH_JOIN [$$54][$$63] |PARTITIONED|
35 -- ONE_TO_ONE_EXCHANGE |PARTITIONED|
36 -- STREAM_PROJECT |PARTITIONED|
37 -- ONE_TO_ONE_EXCHANGE |PARTITIONED|
38 -- HYBRID_HASH_JOIN [$$54][$$55] |PARTITIONED|
39 -- ONE_TO_ONE_EXCHANGE |PARTITIONED|
40 -- STREAM_PROJECT |PARTITIONED|
41 -- ONE_TO_ONE_EXCHANGE |PARTITIONED|
42 -- DATASOURCE_SCAN |PARTITIONED|
buyingyibd904112014-10-27 18:41:43 -070043 -- ONE_TO_ONE_EXCHANGE |PARTITIONED|
buyingyia9a02022015-01-15 10:40:15 -080044 -- EMPTY_TUPLE_SOURCE |PARTITIONED|
45 -- ONE_TO_ONE_EXCHANGE |PARTITIONED|
46 -- STREAM_PROJECT |PARTITIONED|
47 -- ONE_TO_ONE_EXCHANGE |PARTITIONED|
48 -- DATASOURCE_SCAN |PARTITIONED|
49 -- ONE_TO_ONE_EXCHANGE |PARTITIONED|
50 -- EMPTY_TUPLE_SOURCE |PARTITIONED|
51 -- HASH_PARTITION_EXCHANGE [$$63] |PARTITIONED|
52 -- STREAM_PROJECT |PARTITIONED|
53 -- ASSIGN |PARTITIONED|
54 -- ONE_TO_ONE_EXCHANGE |PARTITIONED|
55 -- DATASOURCE_SCAN |PARTITIONED|
buyingyibd904112014-10-27 18:41:43 -070056 -- ONE_TO_ONE_EXCHANGE |PARTITIONED|
buyingyia9a02022015-01-15 10:40:15 -080057 -- EMPTY_TUPLE_SOURCE |PARTITIONED|
58 -- HASH_PARTITION_EXCHANGE [$$60] |PARTITIONED|
59 -- STREAM_PROJECT |PARTITIONED|
60 -- ASSIGN |PARTITIONED|
61 -- STREAM_PROJECT |PARTITIONED|
62 -- ONE_TO_ONE_EXCHANGE |PARTITIONED|
63 -- DATASOURCE_SCAN |PARTITIONED|
64 -- ONE_TO_ONE_EXCHANGE |PARTITIONED|
65 -- EMPTY_TUPLE_SOURCE |PARTITIONED|