http://git-wip-us.apache.org/repos/asf/asterixdb-bad/blob/bf1da24d/asterix-bad/src/test/resources/optimizerts/results/channel/channel-unsubscribe.plan
----------------------------------------------------------------------
diff --git
a/asterix-bad/src/test/resources/optimizerts/results/channel/channel-unsubscribe.plan
b/asterix-bad/src/test/resources/optimizerts/results/channel/channel-unsubscribe.plan
index 709ed35..3435ec9 100644
---
a/asterix-bad/src/test/resources/optimizerts/results/channel/channel-unsubscribe.plan
+++
b/asterix-bad/src/test/resources/optimizerts/results/channel/channel-unsubscribe.plan
@@ -35,52 +35,51 @@
-- ASSIGN
|PARTITIONED|
--
STREAM_PROJECT |PARTITIONED|
--
ONE_TO_ONE_EXCHANGE |PARTITIONED|
- --
PRE_CLUSTERED_GROUP_BY[$$122] |PARTITIONED|
+ --
PRE_CLUSTERED_GROUP_BY[$$121] |PARTITIONED|
{
--
AGGREGATE |LOCAL|
-- STREAM_SELECT |LOCAL|
-- NESTED_TUPLE_SOURCE |LOCAL|
}
--
ONE_TO_ONE_EXCHANGE |PARTITIONED|
- --
STABLE_SORT [$$122(ASC)] |PARTITIONED|
- --
HASH_PARTITION_EXCHANGE [$$122] |PARTITIONED|
+ --
STABLE_SORT [$$121(ASC)] |PARTITIONED|
+ --
HASH_PARTITION_EXCHANGE [$$121] |PARTITIONED|
--
STREAM_PROJECT |PARTITIONED|
--
ONE_TO_ONE_EXCHANGE |PARTITIONED|
-
-- HYBRID_HASH_JOIN [$$97][$$99] |PARTITIONED|
-
-- HASH_PARTITION_EXCHANGE [$$97] |PARTITIONED|
+
-- HYBRID_HASH_JOIN [$$120][$$99] |PARTITIONED|
+
-- ONE_TO_ONE_EXCHANGE |PARTITIONED|
-- ASSIGN |PARTITIONED|
-- STREAM_PROJECT |PARTITIONED|
-- UNNEST |PARTITIONED|
-
-- STREAM_PROJECT |PARTITIONED|
-
-- ONE_TO_ONE_EXCHANGE |PARTITIONED|
-
-- PRE_CLUSTERED_GROUP_BY[$$119] |PARTITIONED|
-
{
-
-- AGGREGATE |LOCAL|
-
-- STREAM_SELECT |LOCAL|
-
-- NESTED_TUPLE_SOURCE |LOCAL|
-
}
-
-- ONE_TO_ONE_EXCHANGE |PARTITIONED|
-
-- STABLE_SORT [$$119(ASC)] |PARTITIONED|
-
-- HASH_PARTITION_EXCHANGE [$$119] |PARTITIONED|
-
-- STREAM_PROJECT |PARTITIONED|
-
-- ONE_TO_ONE_EXCHANGE |PARTITIONED|
-
-- NESTED_LOOP |PARTITIONED|
-
-- ONE_TO_ONE_EXCHANGE |PARTITIONED|
-
-- STREAM_PROJECT |PARTITIONED|
-
-- ASSIGN |PARTITIONED|
+
-- ONE_TO_ONE_EXCHANGE |PARTITIONED|
+
-- PRE_CLUSTERED_GROUP_BY[$$97] |PARTITIONED|
+
{
+
-- AGGREGATE |LOCAL|
+
-- STREAM_SELECT |LOCAL|
+
-- NESTED_TUPLE_SOURCE |LOCAL|
+
}
+
-- ONE_TO_ONE_EXCHANGE |PARTITIONED|
+
-- STABLE_SORT [$$97(ASC)] |PARTITIONED|
+
-- HASH_PARTITION_EXCHANGE [$$97] |PARTITIONED|
+
-- STREAM_PROJECT |PARTITIONED|
+
-- ONE_TO_ONE_EXCHANGE |PARTITIONED|
+
-- NESTED_LOOP |PARTITIONED|
+
-- ONE_TO_ONE_EXCHANGE |PARTITIONED|
+
-- STREAM_PROJECT |PARTITIONED|
+
-- ASSIGN |PARTITIONED|
+
-- ONE_TO_ONE_EXCHANGE |PARTITIONED|
+
-- DATASOURCE_SCAN |PARTITIONED|
+
-- BROADCAST_EXCHANGE |PARTITIONED|
+
-- ASSIGN |UNPARTITIONED|
+
-- EMPTY_TUPLE_SOURCE |UNPARTITIONED|
+
-- BROADCAST_EXCHANGE |PARTITIONED|
+
-- STREAM_PROJECT |PARTITIONED|
+
-- ASSIGN |PARTITIONED|
+
-- STREAM_PROJECT |PARTITIONED|
-- ONE_TO_ONE_EXCHANGE |PARTITIONED|
-- DATASOURCE_SCAN |PARTITIONED|
-
-- BROADCAST_EXCHANGE |PARTITIONED|
-
-- ASSIGN |UNPARTITIONED|
-
-- EMPTY_TUPLE_SOURCE |UNPARTITIONED|
-
-- BROADCAST_EXCHANGE |PARTITIONED|
-
-- STREAM_PROJECT |PARTITIONED|
-
-- ASSIGN |PARTITIONED|
-
-- STREAM_PROJECT |PARTITIONED|
-
-- ONE_TO_ONE_EXCHANGE |PARTITIONED|
-
-- DATASOURCE_SCAN |PARTITIONED|
-
-- ONE_TO_ONE_EXCHANGE |PARTITIONED|
-
-- EMPTY_TUPLE_SOURCE |PARTITIONED|
+
-- ONE_TO_ONE_EXCHANGE |PARTITIONED|
+
-- EMPTY_TUPLE_SOURCE |PARTITIONED|
-- HASH_PARTITION_EXCHANGE [$$99] |PARTITIONED|
-- ASSIGN |PARTITIONED|
-- STREAM_PROJECT |PARTITIONED|
@@ -114,4 +113,4 @@
-- ONE_TO_ONE_EXCHANGE |PARTITIONED|
-- DATASOURCE_SCAN |PARTITIONED|
-- ONE_TO_ONE_EXCHANGE |PARTITIONED|
- -- EMPTY_TUPLE_SOURCE |PARTITIONED|
+ -- EMPTY_TUPLE_SOURCE |PARTITIONED|
\ No newline at end of file
