blob: 93fe350486a01de04685bdb59be3b98818c6816f [file] [log] [blame]
madhusudancs@gmail.com4decba72013-03-20 13:33:50 +00001-- DISTRIBUTE_RESULT |PARTITIONED|
2 -- ONE_TO_ONE_EXCHANGE |PARTITIONED|
3 -- STREAM_PROJECT |PARTITIONED|
4 -- ASSIGN |PARTITIONED|
5 -- STREAM_PROJECT |PARTITIONED|
6 -- SORT_MERGE_EXCHANGE [$$31(ASC) ] |PARTITIONED|
7 -- STABLE_SORT [$$31(ASC)] |PARTITIONED|
8 -- ONE_TO_ONE_EXCHANGE |PARTITIONED|
9 -- STREAM_PROJECT |PARTITIONED|
10 -- ONE_TO_ONE_EXCHANGE |PARTITIONED|
11 -- PRE_CLUSTERED_GROUP_BY[$$27] |PARTITIONED|
12 {
13 -- AGGREGATE |LOCAL|
14 -- IN_MEMORY_STABLE_SORT [$$4(ASC)] |LOCAL|
15 -- STREAM_SELECT |LOCAL|
16 -- NESTED_TUPLE_SOURCE |LOCAL|
17 }
18 -- ONE_TO_ONE_EXCHANGE |PARTITIONED|
19 -- STREAM_PROJECT |PARTITIONED|
20 -- ONE_TO_ONE_EXCHANGE |PARTITIONED|
21 -- IN_MEMORY_HASH_JOIN [$$2][$$7] |PARTITIONED|
22 -- ONE_TO_ONE_EXCHANGE |PARTITIONED|
alexander.behm905948b2012-12-06 09:06:45 +000023 -- STREAM_PROJECT |PARTITIONED|
madhusudancs@gmail.com4decba72013-03-20 13:33:50 +000024 -- UNNEST |PARTITIONED|
25 -- STREAM_PROJECT |PARTITIONED|
26 -- ASSIGN |PARTITIONED|
27 -- ONE_TO_ONE_EXCHANGE |PARTITIONED|
28 -- DATASOURCE_SCAN |PARTITIONED|
29 -- ONE_TO_ONE_EXCHANGE |PARTITIONED|
30 -- EMPTY_TUPLE_SOURCE |PARTITIONED|
31 -- BROADCAST_EXCHANGE |PARTITIONED|
32 -- RUNNING_AGGREGATE |PARTITIONED|
33 -- STREAM_PROJECT |PARTITIONED|
34 -- SORT_MERGE_EXCHANGE [$$28(ASC), $$7(ASC) ] |PARTITIONED|
35 -- STABLE_SORT [$$28(ASC), $$7(ASC)] |PARTITIONED|
36 -- ONE_TO_ONE_EXCHANGE |PARTITIONED|
37 -- EXTERNAL_GROUP_BY[$$36] |PARTITIONED|
38 {
39 -- AGGREGATE |LOCAL|
40 -- NESTED_TUPLE_SOURCE |LOCAL|
41 }
42 -- HASH_PARTITION_EXCHANGE [$$36] |PARTITIONED|
43 -- EXTERNAL_GROUP_BY[$$6] |PARTITIONED|
44 {
45 -- AGGREGATE |LOCAL|
46 -- NESTED_TUPLE_SOURCE |LOCAL|
47 }
48 -- ONE_TO_ONE_EXCHANGE |PARTITIONED|
49 -- STREAM_PROJECT |PARTITIONED|
50 -- UNNEST |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|