blob: f1a7172200805961dae0ebc9ea45b68e0be8870a [file] [log] [blame]
vinayakb38b7ca42012-03-05 05:44:15 +00001-- SINK |PARTITIONED|
2 -- ONE_TO_ONE_EXCHANGE |PARTITIONED|
3 -- INSERT_DELETE |PARTITIONED|
4 -- ONE_TO_ONE_EXCHANGE |LOCAL|
5 -- STABLE_SORT [$$21(ASC)] |LOCAL|
6 -- HASH_PARTITION_EXCHANGE [$$21] |PARTITIONED|
7 -- ASSIGN |PARTITIONED|
8 -- STREAM_PROJECT |PARTITIONED|
9 -- ASSIGN |PARTITIONED|
10 -- ASSIGN |PARTITIONED|
11 -- STREAM_SELECT |PARTITIONED|
12 -- ASSIGN |PARTITIONED|
13 -- ONE_TO_ONE_EXCHANGE |PARTITIONED|
14 -- DATASOURCE_SCAN |PARTITIONED|
15 -- ONE_TO_ONE_EXCHANGE |PARTITIONED|
16 -- EMPTY_TUPLE_SOURCE |PARTITIONED|