blob: e74eaeede1a5f8310cdcca9ec5b13d4d847d9855 [file] [log] [blame]
vinayakb38b7ca42012-03-05 05:44:15 +00001-- SINK_WRITE |PARTITIONED|
2 -- RANDOM_MERGE_EXCHANGE |PARTITIONED|
3 -- STREAM_PROJECT |PARTITIONED|
4 -- ASSIGN |PARTITIONED|
5 -- ONE_TO_ONE_EXCHANGE |PARTITIONED|
6 -- PRE_CLUSTERED_GROUP_BY[$$15] |PARTITIONED|
7 {
8 -- AGGREGATE |LOCAL|
9 -- STREAM_SELECT |LOCAL|
10 -- NESTED_TUPLE_SOURCE |LOCAL|
11 }
12 -- ONE_TO_ONE_EXCHANGE |LOCAL|
13 -- STABLE_SORT [$$15(ASC)] |LOCAL|
14 -- HASH_PARTITION_EXCHANGE [$$15] |PARTITIONED|
15 -- STREAM_PROJECT |PARTITIONED|
16 -- ONE_TO_ONE_EXCHANGE |PARTITIONED|
17 -- HYBRID_HASH_JOIN [$$17][$$16] |PARTITIONED|
18 -- HASH_PARTITION_EXCHANGE [$$17] |PARTITIONED|
19 -- STREAM_PROJECT |PARTITIONED|
20 -- ASSIGN |PARTITIONED|
21 -- ONE_TO_ONE_EXCHANGE |PARTITIONED|
22 -- DATASOURCE_SCAN |PARTITIONED|
23 -- ONE_TO_ONE_EXCHANGE |PARTITIONED|
24 -- EMPTY_TUPLE_SOURCE |PARTITIONED|
25 -- HASH_PARTITION_EXCHANGE [$$16] |PARTITIONED|
26 -- STREAM_PROJECT |PARTITIONED|
27 -- ASSIGN |PARTITIONED|
28 -- ONE_TO_ONE_EXCHANGE |PARTITIONED|
29 -- DATASOURCE_SCAN |PARTITIONED|
30 -- ONE_TO_ONE_EXCHANGE |PARTITIONED|
31 -- EMPTY_TUPLE_SOURCE |PARTITIONED|