Repository: asterixdb-bad Updated Branches: refs/heads/master a2699a43d -> 0fb6b2302
Coordinated Change for ASTERIXDB-2170 Change-Id: I96d46b159f1705c644d595f77e5a7c9c9e925375 Project: http://git-wip-us.apache.org/repos/asf/asterixdb-bad/repo Commit: http://git-wip-us.apache.org/repos/asf/asterixdb-bad/commit/0fb6b230 Tree: http://git-wip-us.apache.org/repos/asf/asterixdb-bad/tree/0fb6b230 Diff: http://git-wip-us.apache.org/repos/asf/asterixdb-bad/diff/0fb6b230 Branch: refs/heads/master Commit: 0fb6b2302ec95ab14085ac17a8b17d0662e774ad Parents: a2699a4 Author: Steven Glenn Jacobs <[email protected]> Authored: Mon Dec 11 10:28:15 2017 -0800 Committer: Steven Jacobs <[email protected]> Committed: Fri Dec 15 12:16:45 2017 -0800 ---------------------------------------------------------------------- .../results/channel/channel-advanced.plan | 34 ++++++++++---------- .../results/channel/channel-create.plan | 18 +++++------ .../results/channel/channel-subscribe.plan | 18 +++++------ .../results/channel/channel-unsubscribe.plan | 18 +++++------ 4 files changed, 44 insertions(+), 44 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/asterixdb-bad/blob/0fb6b230/asterix-bad/src/test/resources/optimizerts/results/channel/channel-advanced.plan ---------------------------------------------------------------------- diff --git a/asterix-bad/src/test/resources/optimizerts/results/channel/channel-advanced.plan b/asterix-bad/src/test/resources/optimizerts/results/channel/channel-advanced.plan index 907044b..d9e613d 100644 --- a/asterix-bad/src/test/resources/optimizerts/results/channel/channel-advanced.plan +++ b/asterix-bad/src/test/resources/optimizerts/results/channel/channel-advanced.plan @@ -1,17 +1,17 @@ -- NOTIFY_BROKERS |PARTITIONED| -- ONE_TO_ONE_EXCHANGE |PARTITIONED| - -- PRE_CLUSTERED_GROUP_BY[$$76, $$channelExecutionTime] |PARTITIONED| + -- PRE_CLUSTERED_GROUP_BY[$$133, $$channelExecutionTime] |PARTITIONED| { -- AGGREGATE |LOCAL| -- NESTED_TUPLE_SOURCE |LOCAL| } -- ONE_TO_ONE_EXCHANGE |PARTITIONED| - -- STABLE_SORT [$$76(ASC), $$channelExecutionTime(ASC)] |PARTITIONED| - -- HASH_PARTITION_EXCHANGE [$$76, $$channelExecutionTime] |PARTITIONED| + -- STABLE_SORT [$$133(ASC), $$channelExecutionTime(ASC)] |PARTITIONED| + -- HASH_PARTITION_EXCHANGE [$$133, $$channelExecutionTime] |PARTITIONED| -- PRE_SORTED_DISTINCT_BY |PARTITIONED| -- ONE_TO_ONE_EXCHANGE |PARTITIONED| - -- STABLE_SORT [$$51(ASC)] |PARTITIONED| - -- HASH_PARTITION_EXCHANGE [$$51] |PARTITIONED| + -- STABLE_SORT [$$108(ASC)] |PARTITIONED| + -- HASH_PARTITION_EXCHANGE [$$108] |PARTITIONED| -- STREAM_PROJECT |PARTITIONED| -- COMMIT |PARTITIONED| -- STREAM_PROJECT |PARTITIONED| @@ -21,7 +21,7 @@ -- STREAM_PROJECT |PARTITIONED| -- ONE_TO_ONE_EXCHANGE |PARTITIONED| -- INSERT_DELETE |PARTITIONED| - -- HASH_PARTITION_EXCHANGE [$$47] |PARTITIONED| + -- HASH_PARTITION_EXCHANGE [$$104] |PARTITIONED| -- ASSIGN |PARTITIONED| -- STREAM_PROJECT |PARTITIONED| -- ASSIGN |PARTITIONED| @@ -33,12 +33,12 @@ -- STREAM_SELECT |PARTITIONED| -- STREAM_PROJECT |PARTITIONED| -- ONE_TO_ONE_EXCHANGE |PARTITIONED| - -- HYBRID_HASH_JOIN [$$61][$$60] |PARTITIONED| - -- HASH_PARTITION_EXCHANGE [$$61] |PARTITIONED| + -- HYBRID_HASH_JOIN [$$118][$$117] |PARTITIONED| + -- HASH_PARTITION_EXCHANGE [$$118] |PARTITIONED| -- STREAM_PROJECT |PARTITIONED| -- ONE_TO_ONE_EXCHANGE |PARTITIONED| - -- HYBRID_HASH_JOIN [$$59, $$57][$$52, $$53] |PARTITIONED| - -- HASH_PARTITION_EXCHANGE [$$59, $$57] |PARTITIONED| + -- HYBRID_HASH_JOIN [$$116, $$114][$$109, $$110] |PARTITIONED| + -- HASH_PARTITION_EXCHANGE [$$116, $$114] |PARTITIONED| -- STREAM_PROJECT |PARTITIONED| -- ASSIGN |PARTITIONED| -- ONE_TO_ONE_EXCHANGE |PARTITIONED| @@ -46,24 +46,24 @@ -- BROADCAST_EXCHANGE |PARTITIONED| -- ASSIGN |UNPARTITIONED| -- EMPTY_TUPLE_SOURCE |UNPARTITIONED| - -- HASH_PARTITION_EXCHANGE [$$52, $$53] |PARTITIONED| + -- HASH_PARTITION_EXCHANGE [$$109, $$110] |PARTITIONED| -- STREAM_PROJECT |PARTITIONED| -- ASSIGN |PARTITIONED| -- ONE_TO_ONE_EXCHANGE |PARTITIONED| -- DATASOURCE_SCAN |PARTITIONED| -- ONE_TO_ONE_EXCHANGE |PARTITIONED| -- EMPTY_TUPLE_SOURCE |PARTITIONED| - -- HASH_PARTITION_EXCHANGE [$$60] |PARTITIONED| + -- HASH_PARTITION_EXCHANGE [$$117] |PARTITIONED| -- STREAM_PROJECT |PARTITIONED| -- ONE_TO_ONE_EXCHANGE |PARTITIONED| - -- HYBRID_HASH_JOIN [$$54][$$70] |PARTITIONED| + -- HYBRID_HASH_JOIN [$$111][$$127] |PARTITIONED| -- ONE_TO_ONE_EXCHANGE |PARTITIONED| -- STREAM_SELECT |PARTITIONED| -- ASSIGN |PARTITIONED| -- ONE_TO_ONE_EXCHANGE |PARTITIONED| -- BTREE_SEARCH |PARTITIONED| -- ONE_TO_ONE_EXCHANGE |PARTITIONED| - -- STABLE_SORT [$$80(ASC)] |PARTITIONED| + -- STABLE_SORT [$$137(ASC)] |PARTITIONED| -- ONE_TO_ONE_EXCHANGE |PARTITIONED| -- STREAM_PROJECT |PARTITIONED| -- ONE_TO_ONE_EXCHANGE |PARTITIONED| @@ -71,7 +71,7 @@ -- ONE_TO_ONE_EXCHANGE |PARTITIONED| -- ASSIGN |PARTITIONED| -- EMPTY_TUPLE_SOURCE |PARTITIONED| - -- HASH_PARTITION_EXCHANGE [$$70] |PARTITIONED| + -- HASH_PARTITION_EXCHANGE [$$127] |PARTITIONED| -- NESTED_LOOP |PARTITIONED| -- ONE_TO_ONE_EXCHANGE |PARTITIONED| -- STREAM_PROJECT |PARTITIONED| @@ -79,7 +79,7 @@ -- ONE_TO_ONE_EXCHANGE |PARTITIONED| -- BTREE_SEARCH |PARTITIONED| -- ONE_TO_ONE_EXCHANGE |PARTITIONED| - -- STABLE_SORT [$$84(ASC)] |PARTITIONED| + -- STABLE_SORT [$$141(ASC)] |PARTITIONED| -- ONE_TO_ONE_EXCHANGE |PARTITIONED| -- STREAM_PROJECT |PARTITIONED| -- ONE_TO_ONE_EXCHANGE |PARTITIONED| @@ -94,7 +94,7 @@ -- ONE_TO_ONE_EXCHANGE |PARTITIONED| -- BTREE_SEARCH |PARTITIONED| -- ONE_TO_ONE_EXCHANGE |PARTITIONED| - -- STABLE_SORT [$$87(ASC)] |PARTITIONED| + -- STABLE_SORT [$$144(ASC)] |PARTITIONED| -- ONE_TO_ONE_EXCHANGE |PARTITIONED| -- STREAM_PROJECT |PARTITIONED| -- ONE_TO_ONE_EXCHANGE |PARTITIONED| http://git-wip-us.apache.org/repos/asf/asterixdb-bad/blob/0fb6b230/asterix-bad/src/test/resources/optimizerts/results/channel/channel-create.plan ---------------------------------------------------------------------- diff --git a/asterix-bad/src/test/resources/optimizerts/results/channel/channel-create.plan b/asterix-bad/src/test/resources/optimizerts/results/channel/channel-create.plan index a352739..374e30e 100644 --- a/asterix-bad/src/test/resources/optimizerts/results/channel/channel-create.plan +++ b/asterix-bad/src/test/resources/optimizerts/results/channel/channel-create.plan @@ -1,17 +1,17 @@ -- NOTIFY_BROKERS |PARTITIONED| -- ONE_TO_ONE_EXCHANGE |PARTITIONED| - -- PRE_CLUSTERED_GROUP_BY[$$52, $$channelExecutionTime] |PARTITIONED| + -- PRE_CLUSTERED_GROUP_BY[$$86, $$channelExecutionTime] |PARTITIONED| { -- AGGREGATE |LOCAL| -- NESTED_TUPLE_SOURCE |LOCAL| } -- ONE_TO_ONE_EXCHANGE |PARTITIONED| - -- STABLE_SORT [$$52(ASC), $$channelExecutionTime(ASC)] |PARTITIONED| - -- HASH_PARTITION_EXCHANGE [$$52, $$channelExecutionTime] |PARTITIONED| + -- STABLE_SORT [$$86(ASC), $$channelExecutionTime(ASC)] |PARTITIONED| + -- HASH_PARTITION_EXCHANGE [$$86, $$channelExecutionTime] |PARTITIONED| -- PRE_SORTED_DISTINCT_BY |PARTITIONED| -- ONE_TO_ONE_EXCHANGE |PARTITIONED| - -- STABLE_SORT [$$37(ASC)] |PARTITIONED| - -- HASH_PARTITION_EXCHANGE [$$37] |PARTITIONED| + -- STABLE_SORT [$$71(ASC)] |PARTITIONED| + -- HASH_PARTITION_EXCHANGE [$$71] |PARTITIONED| -- STREAM_PROJECT |PARTITIONED| -- COMMIT |PARTITIONED| -- STREAM_PROJECT |PARTITIONED| @@ -21,7 +21,7 @@ -- STREAM_PROJECT |PARTITIONED| -- ONE_TO_ONE_EXCHANGE |PARTITIONED| -- INSERT_DELETE |PARTITIONED| - -- HASH_PARTITION_EXCHANGE [$$32] |PARTITIONED| + -- HASH_PARTITION_EXCHANGE [$$66] |PARTITIONED| -- ASSIGN |PARTITIONED| -- STREAM_PROJECT |PARTITIONED| -- ASSIGN |PARTITIONED| @@ -35,8 +35,8 @@ -- ONE_TO_ONE_EXCHANGE |PARTITIONED| -- STREAM_PROJECT |PARTITIONED| -- ONE_TO_ONE_EXCHANGE |PARTITIONED| - -- HYBRID_HASH_JOIN [$$44, $$42][$$38, $$39] |PARTITIONED| - -- HASH_PARTITION_EXCHANGE [$$44, $$42] |PARTITIONED| + -- HYBRID_HASH_JOIN [$$78, $$76][$$72, $$73] |PARTITIONED| + -- HASH_PARTITION_EXCHANGE [$$78, $$76] |PARTITIONED| -- STREAM_PROJECT |PARTITIONED| -- ASSIGN |PARTITIONED| -- ONE_TO_ONE_EXCHANGE |PARTITIONED| @@ -44,7 +44,7 @@ -- BROADCAST_EXCHANGE |PARTITIONED| -- ASSIGN |UNPARTITIONED| -- EMPTY_TUPLE_SOURCE |UNPARTITIONED| - -- HASH_PARTITION_EXCHANGE [$$38, $$39] |PARTITIONED| + -- HASH_PARTITION_EXCHANGE [$$72, $$73] |PARTITIONED| -- STREAM_PROJECT |PARTITIONED| -- ASSIGN |PARTITIONED| -- ONE_TO_ONE_EXCHANGE |PARTITIONED| http://git-wip-us.apache.org/repos/asf/asterixdb-bad/blob/0fb6b230/asterix-bad/src/test/resources/optimizerts/results/channel/channel-subscribe.plan ---------------------------------------------------------------------- diff --git a/asterix-bad/src/test/resources/optimizerts/results/channel/channel-subscribe.plan b/asterix-bad/src/test/resources/optimizerts/results/channel/channel-subscribe.plan index 7ad21f6..8c2ba14 100644 --- a/asterix-bad/src/test/resources/optimizerts/results/channel/channel-subscribe.plan +++ b/asterix-bad/src/test/resources/optimizerts/results/channel/channel-subscribe.plan @@ -1,17 +1,17 @@ -- NOTIFY_BROKERS |PARTITIONED| -- ONE_TO_ONE_EXCHANGE |PARTITIONED| - -- PRE_CLUSTERED_GROUP_BY[$$52, $$channelExecutionTime] |PARTITIONED| + -- PRE_CLUSTERED_GROUP_BY[$$86, $$channelExecutionTime] |PARTITIONED| { -- AGGREGATE |LOCAL| -- NESTED_TUPLE_SOURCE |LOCAL| } -- ONE_TO_ONE_EXCHANGE |PARTITIONED| - -- STABLE_SORT [$$52(ASC), $$channelExecutionTime(ASC)] |PARTITIONED| - -- HASH_PARTITION_EXCHANGE [$$52, $$channelExecutionTime] |PARTITIONED| + -- STABLE_SORT [$$86(ASC), $$channelExecutionTime(ASC)] |PARTITIONED| + -- HASH_PARTITION_EXCHANGE [$$86, $$channelExecutionTime] |PARTITIONED| -- PRE_SORTED_DISTINCT_BY |PARTITIONED| -- ONE_TO_ONE_EXCHANGE |PARTITIONED| - -- STABLE_SORT [$$37(ASC)] |PARTITIONED| - -- HASH_PARTITION_EXCHANGE [$$37] |PARTITIONED| + -- STABLE_SORT [$$71(ASC)] |PARTITIONED| + -- HASH_PARTITION_EXCHANGE [$$71] |PARTITIONED| -- STREAM_PROJECT |PARTITIONED| -- COMMIT |PARTITIONED| -- STREAM_PROJECT |PARTITIONED| @@ -21,7 +21,7 @@ -- STREAM_PROJECT |PARTITIONED| -- ONE_TO_ONE_EXCHANGE |PARTITIONED| -- INSERT_DELETE |PARTITIONED| - -- HASH_PARTITION_EXCHANGE [$$32] |PARTITIONED| + -- HASH_PARTITION_EXCHANGE [$$66] |PARTITIONED| -- ASSIGN |PARTITIONED| -- STREAM_PROJECT |PARTITIONED| -- ASSIGN |PARTITIONED| @@ -35,8 +35,8 @@ -- ONE_TO_ONE_EXCHANGE |PARTITIONED| -- STREAM_PROJECT |PARTITIONED| -- ONE_TO_ONE_EXCHANGE |PARTITIONED| - -- HYBRID_HASH_JOIN [$$44, $$42][$$38, $$39] |PARTITIONED| - -- HASH_PARTITION_EXCHANGE [$$44, $$42] |PARTITIONED| + -- HYBRID_HASH_JOIN [$$78, $$76][$$72, $$73] |PARTITIONED| + -- HASH_PARTITION_EXCHANGE [$$78, $$76] |PARTITIONED| -- STREAM_PROJECT |PARTITIONED| -- ASSIGN |PARTITIONED| -- ONE_TO_ONE_EXCHANGE |PARTITIONED| @@ -44,7 +44,7 @@ -- BROADCAST_EXCHANGE |PARTITIONED| -- ASSIGN |UNPARTITIONED| -- EMPTY_TUPLE_SOURCE |UNPARTITIONED| - -- HASH_PARTITION_EXCHANGE [$$38, $$39] |PARTITIONED| + -- HASH_PARTITION_EXCHANGE [$$72, $$73] |PARTITIONED| -- STREAM_PROJECT |PARTITIONED| -- ASSIGN |PARTITIONED| -- ONE_TO_ONE_EXCHANGE |PARTITIONED| http://git-wip-us.apache.org/repos/asf/asterixdb-bad/blob/0fb6b230/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 3338e79..84c707b 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 @@ -1,17 +1,17 @@ -- NOTIFY_BROKERS |PARTITIONED| -- ONE_TO_ONE_EXCHANGE |PARTITIONED| - -- PRE_CLUSTERED_GROUP_BY[$$52, $$channelExecutionTime] |PARTITIONED| + -- PRE_CLUSTERED_GROUP_BY[$$86, $$channelExecutionTime] |PARTITIONED| { -- AGGREGATE |LOCAL| -- NESTED_TUPLE_SOURCE |LOCAL| } -- ONE_TO_ONE_EXCHANGE |PARTITIONED| - -- STABLE_SORT [$$52(ASC), $$channelExecutionTime(ASC)] |PARTITIONED| - -- HASH_PARTITION_EXCHANGE [$$52, $$channelExecutionTime] |PARTITIONED| + -- STABLE_SORT [$$86(ASC), $$channelExecutionTime(ASC)] |PARTITIONED| + -- HASH_PARTITION_EXCHANGE [$$86, $$channelExecutionTime] |PARTITIONED| -- PRE_SORTED_DISTINCT_BY |PARTITIONED| -- ONE_TO_ONE_EXCHANGE |PARTITIONED| - -- STABLE_SORT [$$37(ASC)] |PARTITIONED| - -- HASH_PARTITION_EXCHANGE [$$37] |PARTITIONED| + -- STABLE_SORT [$$71(ASC)] |PARTITIONED| + -- HASH_PARTITION_EXCHANGE [$$71] |PARTITIONED| -- STREAM_PROJECT |PARTITIONED| -- COMMIT |PARTITIONED| -- STREAM_PROJECT |PARTITIONED| @@ -21,7 +21,7 @@ -- STREAM_PROJECT |PARTITIONED| -- ONE_TO_ONE_EXCHANGE |PARTITIONED| -- INSERT_DELETE |PARTITIONED| - -- HASH_PARTITION_EXCHANGE [$$32] |PARTITIONED| + -- HASH_PARTITION_EXCHANGE [$$66] |PARTITIONED| -- ASSIGN |PARTITIONED| -- STREAM_PROJECT |PARTITIONED| -- ASSIGN |PARTITIONED| @@ -35,8 +35,8 @@ -- ONE_TO_ONE_EXCHANGE |PARTITIONED| -- STREAM_PROJECT |PARTITIONED| -- ONE_TO_ONE_EXCHANGE |PARTITIONED| - -- HYBRID_HASH_JOIN [$$44, $$42][$$38, $$39] |PARTITIONED| - -- HASH_PARTITION_EXCHANGE [$$44, $$42] |PARTITIONED| + -- HYBRID_HASH_JOIN [$$78, $$76][$$72, $$73] |PARTITIONED| + -- HASH_PARTITION_EXCHANGE [$$78, $$76] |PARTITIONED| -- STREAM_PROJECT |PARTITIONED| -- ASSIGN |PARTITIONED| -- ONE_TO_ONE_EXCHANGE |PARTITIONED| @@ -44,7 +44,7 @@ -- BROADCAST_EXCHANGE |PARTITIONED| -- ASSIGN |UNPARTITIONED| -- EMPTY_TUPLE_SOURCE |UNPARTITIONED| - -- HASH_PARTITION_EXCHANGE [$$38, $$39] |PARTITIONED| + -- HASH_PARTITION_EXCHANGE [$$72, $$73] |PARTITIONED| -- STREAM_PROJECT |PARTITIONED| -- ASSIGN |PARTITIONED| -- ONE_TO_ONE_EXCHANGE |PARTITIONED|
