blob: 7c4a8c2424e72acf3d3e00285c59da60334fe60b [file] [log] [blame]
Yingyi Bue3e13732015-12-30 16:06:04 -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 -- HYBRID_HASH_JOIN [$$39][$$34] |PARTITIONED|
8 -- ONE_TO_ONE_EXCHANGE |PARTITIONED|
9 -- STREAM_PROJECT |PARTITIONED|
10 -- ONE_TO_ONE_EXCHANGE |PARTITIONED|
11 -- DATASOURCE_SCAN |PARTITIONED|
12 -- ONE_TO_ONE_EXCHANGE |PARTITIONED|
13 -- EMPTY_TUPLE_SOURCE |PARTITIONED|
14 -- HASH_PARTITION_EXCHANGE [$$34] |PARTITIONED|
15 -- STREAM_PROJECT |PARTITIONED|
16 -- ASSIGN |PARTITIONED|
17 -- ONE_TO_ONE_EXCHANGE |PARTITIONED|
18 -- PRE_CLUSTERED_GROUP_BY[$$41] |PARTITIONED|
19 {
20 -- AGGREGATE |LOCAL|
21 -- STREAM_SELECT |LOCAL|
22 -- NESTED_TUPLE_SOURCE |LOCAL|
23 }
24 -- ONE_TO_ONE_EXCHANGE |PARTITIONED|
25 -- STABLE_SORT [$$41(ASC)] |PARTITIONED|
26 -- HASH_PARTITION_EXCHANGE [$$41] |PARTITIONED|
27 -- STREAM_PROJECT |PARTITIONED|
28 -- ONE_TO_ONE_EXCHANGE |PARTITIONED|
29 -- NESTED_LOOP |PARTITIONED|
30 -- BROADCAST_EXCHANGE |PARTITIONED|
31 -- STREAM_PROJECT |PARTITIONED|
32 -- STREAM_SELECT |PARTITIONED|
33 -- ONE_TO_ONE_EXCHANGE |PARTITIONED|
34 -- PRE_CLUSTERED_GROUP_BY[$$47] |PARTITIONED|
35 {
36 -- AGGREGATE |LOCAL|
37 -- STREAM_SELECT |LOCAL|
38 -- NESTED_TUPLE_SOURCE |LOCAL|
39 }
40 -- ONE_TO_ONE_EXCHANGE |PARTITIONED|
41 -- STABLE_SORT [$$47(ASC)] |PARTITIONED|
42 -- HASH_PARTITION_EXCHANGE [$$47] |PARTITIONED|
43 -- STREAM_PROJECT |PARTITIONED|
44 -- ONE_TO_ONE_EXCHANGE |PARTITIONED|
45 -- HYBRID_HASH_JOIN [$$45][$$42] |PARTITIONED|
46 -- HASH_PARTITION_EXCHANGE [$$45] |PARTITIONED|
47 -- NESTED_LOOP |PARTITIONED|
48 -- BROADCAST_EXCHANGE |PARTITIONED|
49 -- STREAM_PROJECT |PARTITIONED|
50 -- ASSIGN |PARTITIONED|
51 -- ONE_TO_ONE_EXCHANGE |PARTITIONED|
52 -- DATASOURCE_SCAN |PARTITIONED|
53 -- ONE_TO_ONE_EXCHANGE |PARTITIONED|
54 -- EMPTY_TUPLE_SOURCE |PARTITIONED|
55 -- ONE_TO_ONE_EXCHANGE |PARTITIONED|
56 -- STREAM_PROJECT |PARTITIONED|
57 -- ASSIGN |PARTITIONED|
58 -- STREAM_PROJECT |PARTITIONED|
59 -- ONE_TO_ONE_EXCHANGE |PARTITIONED|
60 -- DATASOURCE_SCAN |PARTITIONED|
61 -- ONE_TO_ONE_EXCHANGE |PARTITIONED|
62 -- EMPTY_TUPLE_SOURCE |PARTITIONED|
63 -- HASH_PARTITION_EXCHANGE [$$42] |PARTITIONED|
64 -- STREAM_PROJECT |PARTITIONED|
65 -- ASSIGN |PARTITIONED|
66 -- STREAM_PROJECT |PARTITIONED|
67 -- ONE_TO_ONE_EXCHANGE |PARTITIONED|
68 -- DATASOURCE_SCAN |PARTITIONED|
69 -- ONE_TO_ONE_EXCHANGE |PARTITIONED|
70 -- EMPTY_TUPLE_SOURCE |PARTITIONED|
71 -- ONE_TO_ONE_EXCHANGE |PARTITIONED|
72 -- STREAM_PROJECT |PARTITIONED|
73 -- ASSIGN |PARTITIONED|
74 -- STREAM_PROJECT |PARTITIONED|
75 -- ONE_TO_ONE_EXCHANGE |PARTITIONED|
76 -- DATASOURCE_SCAN |PARTITIONED|
77 -- ONE_TO_ONE_EXCHANGE |PARTITIONED|
78 -- EMPTY_TUPLE_SOURCE |PARTITIONED|