blob: c5511fdc0eed351b5296004f851ed780167d3fb2 [file] [log] [blame]
madhusudancs@gmail.com4decba72013-03-20 13:33:50 +00001-- DISTRIBUTE_RESULT |PARTITIONED|
Madhusudan.C.S0bed7f22013-04-17 23:44:41 -07002 -- ONE_TO_ONE_EXCHANGE |PARTITIONED|
vinayakb38b7ca42012-03-05 05:44:15 +00003 -- STREAM_PROJECT |PARTITIONED|
4 -- ASSIGN |PARTITIONED|
alexander.behm905948b2012-12-06 09:06:45 +00005 -- STREAM_PROJECT |PARTITIONED|
6 -- ONE_TO_ONE_EXCHANGE |PARTITIONED|
7 -- PRE_CLUSTERED_GROUP_BY[$$23] |PARTITIONED|
8 {
9 -- AGGREGATE |LOCAL|
10 -- STREAM_SELECT |LOCAL|
11 -- NESTED_TUPLE_SOURCE |LOCAL|
12 }
13 -- ONE_TO_ONE_EXCHANGE |PARTITIONED|
Vinayak Borkar62e66c02013-05-28 13:56:11 -070014 -- STABLE_SORT [$$23(ASC), $$4(ASC)] |PARTITIONED|
alexander.behm905948b2012-12-06 09:06:45 +000015 -- HASH_PARTITION_EXCHANGE [$$23] |PARTITIONED|
16 -- STREAM_PROJECT |PARTITIONED|
17 -- ONE_TO_ONE_EXCHANGE |PARTITIONED|
Vinayak Borkar62e66c02013-05-28 13:56:11 -070018 -- HYBRID_HASH_JOIN [$$1][$$4] |PARTITIONED|
alexander.behm905948b2012-12-06 09:06:45 +000019 -- HASH_PARTITION_EXCHANGE [$$1] |PARTITIONED|
vinayakb38b7ca42012-03-05 05:44:15 +000020 -- STREAM_PROJECT |PARTITIONED|
alexander.behm905948b2012-12-06 09:06:45 +000021 -- UNNEST |PARTITIONED|
22 -- STREAM_PROJECT |PARTITIONED|
23 -- ASSIGN |PARTITIONED|
24 -- ONE_TO_ONE_EXCHANGE |PARTITIONED|
25 -- DATASOURCE_SCAN |PARTITIONED|
26 -- ONE_TO_ONE_EXCHANGE |PARTITIONED|
27 -- EMPTY_TUPLE_SOURCE |PARTITIONED|
Vinayak Borkar62e66c02013-05-28 13:56:11 -070028 -- HASH_PARTITION_EXCHANGE [$$4] |PARTITIONED|
alexander.behm905948b2012-12-06 09:06:45 +000029 -- RUNNING_AGGREGATE |PARTITIONED|
30 -- STREAM_PROJECT |PARTITIONED|
31 -- SORT_MERGE_EXCHANGE [$$24(DESC) ] |PARTITIONED|
32 -- STABLE_SORT [$$24(DESC)] |PARTITIONED|
33 -- ONE_TO_ONE_EXCHANGE |PARTITIONED|
34 -- PRE_CLUSTERED_GROUP_BY[$$30] |PARTITIONED|
35 {
36 -- AGGREGATE |LOCAL|
37 -- NESTED_TUPLE_SOURCE |LOCAL|
38 }
39 -- HASH_PARTITION_MERGE_EXCHANGE MERGE:[$$30(ASC)] HASH:[$$30] |PARTITIONED|
Yingyi Bu362b8842014-05-26 00:01:18 -070040 -- SORT_GROUP_BY[$$3] |PARTITIONED|
alexander.behm905948b2012-12-06 09:06:45 +000041 {
42 -- AGGREGATE |LOCAL|
43 -- NESTED_TUPLE_SOURCE |LOCAL|
44 }
45 -- ONE_TO_ONE_EXCHANGE |PARTITIONED|
Yingyi Bu362b8842014-05-26 00:01:18 -070046 -- STREAM_PROJECT |PARTITIONED|
47 -- UNNEST |PARTITIONED|
alexander.behm905948b2012-12-06 09:06:45 +000048 -- STREAM_PROJECT |PARTITIONED|
Yingyi Bu362b8842014-05-26 00:01:18 -070049 -- ASSIGN |PARTITIONED|
alexander.behm905948b2012-12-06 09:06:45 +000050 -- STREAM_PROJECT |PARTITIONED|
Yingyi Bu362b8842014-05-26 00:01:18 -070051 -- ONE_TO_ONE_EXCHANGE |PARTITIONED|
52 -- DATASOURCE_SCAN |PARTITIONED|
alexander.behm905948b2012-12-06 09:06:45 +000053 -- ONE_TO_ONE_EXCHANGE |PARTITIONED|
Yingyi Bu362b8842014-05-26 00:01:18 -070054 -- EMPTY_TUPLE_SOURCE |PARTITIONED|