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