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