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