blob: a080c79397c493b797a64f45175856aae5ad3e8c [file] [log] [blame]
Steven Glenn Jacobsd0ec8372016-12-07 11:00:08 -08001-- NOTIFY_BROKERS |PARTITIONED|
2 -- ONE_TO_ONE_EXCHANGE |PARTITIONED|
Xikui Wang4e2e7a52018-06-06 11:45:24 -07003 -- PRE_CLUSTERED_GROUP_BY[$$94, $$channelExecutionTime] |PARTITIONED|
Steven Glenn Jacobsd0ec8372016-12-07 11:00:08 -08004 {
5 -- AGGREGATE |LOCAL|
6 -- NESTED_TUPLE_SOURCE |LOCAL|
7 }
8 -- ONE_TO_ONE_EXCHANGE |PARTITIONED|
Xikui Wang4e2e7a52018-06-06 11:45:24 -07009 -- STABLE_SORT [$$94(ASC), $$channelExecutionTime(ASC)] |PARTITIONED|
10 -- HASH_PARTITION_EXCHANGE [$$94, $$channelExecutionTime] |PARTITIONED|
Steven Glenn Jacobsd0ec8372016-12-07 11:00:08 -080011 -- PRE_SORTED_DISTINCT_BY |PARTITIONED|
12 -- ONE_TO_ONE_EXCHANGE |PARTITIONED|
Xikui Wang4e2e7a52018-06-06 11:45:24 -070013 -- STABLE_SORT [$$79(ASC)] |PARTITIONED|
14 -- HASH_PARTITION_EXCHANGE [$$79] |PARTITIONED|
Steven Glenn Jacobsd0ec8372016-12-07 11:00:08 -080015 -- STREAM_PROJECT |PARTITIONED|
16 -- COMMIT |PARTITIONED|
17 -- STREAM_PROJECT |PARTITIONED|
18 -- ONE_TO_ONE_EXCHANGE |PARTITIONED|
Steven Glenn Jacobs8b53ce52017-11-14 10:21:43 -080019 -- INDEX_INSERT_DELETE |PARTITIONED|
20 -- ONE_TO_ONE_EXCHANGE |PARTITIONED|
21 -- STREAM_PROJECT |PARTITIONED|
22 -- ONE_TO_ONE_EXCHANGE |PARTITIONED|
23 -- INSERT_DELETE |PARTITIONED|
Xikui Wang4e2e7a52018-06-06 11:45:24 -070024 -- HASH_PARTITION_EXCHANGE [$$73] |PARTITIONED|
Steven Glenn Jacobsd0ec8372016-12-07 11:00:08 -080025 -- ASSIGN |PARTITIONED|
26 -- STREAM_PROJECT |PARTITIONED|
27 -- ASSIGN |PARTITIONED|
28 -- STREAM_PROJECT |PARTITIONED|
Steven Glenn Jacobs8b53ce52017-11-14 10:21:43 -080029 -- ASSIGN |PARTITIONED|
30 -- STREAM_PROJECT |PARTITIONED|
31 -- ASSIGN |PARTITIONED|
Steven Glenn Jacobsd0ec8372016-12-07 11:00:08 -080032 -- STREAM_PROJECT |PARTITIONED|
33 -- ONE_TO_ONE_EXCHANGE |PARTITIONED|
Steven Glenn Jacobs8b53ce52017-11-14 10:21:43 -080034 -- NESTED_LOOP |PARTITIONED|
Steven Glenn Jacobsd0ec8372016-12-07 11:00:08 -080035 -- ONE_TO_ONE_EXCHANGE |PARTITIONED|
Steven Glenn Jacobs8b53ce52017-11-14 10:21:43 -080036 -- STREAM_PROJECT |PARTITIONED|
Steven Glenn Jacobsd0ec8372016-12-07 11:00:08 -080037 -- ONE_TO_ONE_EXCHANGE |PARTITIONED|
Xikui Wang4e2e7a52018-06-06 11:45:24 -070038 -- HYBRID_HASH_JOIN [$$86, $$84][$$80, $$81] |PARTITIONED|
39 -- HASH_PARTITION_EXCHANGE [$$86, $$84] |PARTITIONED|
Steven Glenn Jacobs8b53ce52017-11-14 10:21:43 -080040 -- STREAM_PROJECT |PARTITIONED|
41 -- ASSIGN |PARTITIONED|
42 -- ONE_TO_ONE_EXCHANGE |PARTITIONED|
43 -- DATASOURCE_SCAN |PARTITIONED|
44 -- BROADCAST_EXCHANGE |PARTITIONED|
45 -- ASSIGN |UNPARTITIONED|
46 -- EMPTY_TUPLE_SOURCE |UNPARTITIONED|
Xikui Wang4e2e7a52018-06-06 11:45:24 -070047 -- HASH_PARTITION_EXCHANGE [$$80, $$81] |PARTITIONED|
Steven Glenn Jacobs8b53ce52017-11-14 10:21:43 -080048 -- STREAM_PROJECT |PARTITIONED|
49 -- ASSIGN |PARTITIONED|
50 -- ONE_TO_ONE_EXCHANGE |PARTITIONED|
51 -- DATASOURCE_SCAN |PARTITIONED|
52 -- ONE_TO_ONE_EXCHANGE |PARTITIONED|
53 -- EMPTY_TUPLE_SOURCE |PARTITIONED|
54 -- BROADCAST_EXCHANGE |PARTITIONED|
55 -- STREAM_PROJECT |PARTITIONED|
56 -- ASSIGN |PARTITIONED|
57 -- STREAM_PROJECT |PARTITIONED|
58 -- ONE_TO_ONE_EXCHANGE |PARTITIONED|
59 -- DATASOURCE_SCAN |PARTITIONED|
60 -- ONE_TO_ONE_EXCHANGE |PARTITIONED|
Xikui Wang4e2e7a52018-06-06 11:45:24 -070061 -- EMPTY_TUPLE_SOURCE |PARTITIONED|