blob: 01242854a6f84c71a60cf16b2f63e86070f50ac9 [file] [log] [blame]
Yingyi Bue3e13732015-12-30 16:06:04 -08001-- COMMIT |PARTITIONED|
2 -- STREAM_PROJECT |PARTITIONED|
3 -- ONE_TO_ONE_EXCHANGE |PARTITIONED|
4 -- INSERT_DELETE |PARTITIONED|
5 -- HASH_PARTITION_EXCHANGE [$$34] |PARTITIONED|
6 -- ASSIGN |PARTITIONED|
7 -- STREAM_PROJECT |PARTITIONED|
8 -- ASSIGN |PARTITIONED|
9 -- STREAM_PROJECT |PARTITIONED|
10 -- ASSIGN |PARTITIONED|
11 -- STREAM_PROJECT |PARTITIONED|
12 -- ASSIGN |PARTITIONED|
13 -- STREAM_PROJECT |PARTITIONED|
14 -- ONE_TO_ONE_EXCHANGE |PARTITIONED|
15 -- HYBRID_HASH_JOIN [$$43][$$38] |PARTITIONED|
16 -- ONE_TO_ONE_EXCHANGE |PARTITIONED|
17 -- STREAM_PROJECT |PARTITIONED|
18 -- ONE_TO_ONE_EXCHANGE |PARTITIONED|
19 -- DATASOURCE_SCAN |PARTITIONED|
20 -- ONE_TO_ONE_EXCHANGE |PARTITIONED|
21 -- EMPTY_TUPLE_SOURCE |PARTITIONED|
22 -- HASH_PARTITION_EXCHANGE [$$38] |PARTITIONED|
23 -- STREAM_PROJECT |PARTITIONED|
24 -- ASSIGN |PARTITIONED|
25 -- ONE_TO_ONE_EXCHANGE |PARTITIONED|
26 -- PRE_CLUSTERED_GROUP_BY[$$45] |PARTITIONED|
27 {
28 -- AGGREGATE |LOCAL|
29 -- STREAM_SELECT |LOCAL|
30 -- NESTED_TUPLE_SOURCE |LOCAL|
31 }
32 -- ONE_TO_ONE_EXCHANGE |PARTITIONED|
33 -- STABLE_SORT [$$45(ASC)] |PARTITIONED|
34 -- HASH_PARTITION_EXCHANGE [$$45] |PARTITIONED|
35 -- STREAM_PROJECT |PARTITIONED|
36 -- ONE_TO_ONE_EXCHANGE |PARTITIONED|
37 -- NESTED_LOOP |PARTITIONED|
38 -- BROADCAST_EXCHANGE |PARTITIONED|
39 -- STREAM_PROJECT |PARTITIONED|
40 -- STREAM_SELECT |PARTITIONED|
41 -- ONE_TO_ONE_EXCHANGE |PARTITIONED|
42 -- PRE_CLUSTERED_GROUP_BY[$$51] |PARTITIONED|
43 {
44 -- AGGREGATE |LOCAL|
45 -- STREAM_SELECT |LOCAL|
46 -- NESTED_TUPLE_SOURCE |LOCAL|
47 }
48 -- ONE_TO_ONE_EXCHANGE |PARTITIONED|
49 -- STABLE_SORT [$$51(ASC)] |PARTITIONED|
50 -- HASH_PARTITION_EXCHANGE [$$51] |PARTITIONED|
51 -- STREAM_PROJECT |PARTITIONED|
52 -- ONE_TO_ONE_EXCHANGE |PARTITIONED|
53 -- HYBRID_HASH_JOIN [$$49][$$46] |PARTITIONED|
54 -- HASH_PARTITION_EXCHANGE [$$49] |PARTITIONED|
55 -- NESTED_LOOP |PARTITIONED|
56 -- BROADCAST_EXCHANGE |PARTITIONED|
57 -- STREAM_PROJECT |PARTITIONED|
58 -- ASSIGN |PARTITIONED|
59 -- ONE_TO_ONE_EXCHANGE |PARTITIONED|
60 -- DATASOURCE_SCAN |PARTITIONED|
61 -- ONE_TO_ONE_EXCHANGE |PARTITIONED|
62 -- EMPTY_TUPLE_SOURCE |PARTITIONED|
63 -- ONE_TO_ONE_EXCHANGE |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 -- HASH_PARTITION_EXCHANGE [$$46] |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|
79 -- ONE_TO_ONE_EXCHANGE |PARTITIONED|
80 -- STREAM_PROJECT |PARTITIONED|
81 -- ASSIGN |PARTITIONED|
82 -- STREAM_PROJECT |PARTITIONED|
83 -- ONE_TO_ONE_EXCHANGE |PARTITIONED|
84 -- DATASOURCE_SCAN |PARTITIONED|
85 -- ONE_TO_ONE_EXCHANGE |PARTITIONED|
86 -- EMPTY_TUPLE_SOURCE |PARTITIONED|