Skip to content
Permalink
Browse files
Match plan printing changes from Asterix
Change-Id: I540f4db9c7d645629ffb57e65ba29c5fe8846760
  • Loading branch information
sjaco002 committed May 9, 2017
1 parent c74595a commit dcbd6d1f55bd5b52277909c81f7dc1ea532d1b77
Showing 5 changed files with 15 additions and 13 deletions.
@@ -92,8 +92,10 @@ public static String formatJSON(EntityId activeJobId, AOrderedList subscriptionI
+ channelExecutionTime + "\", \"subscriptionIds\":[";
for (int i = 0; i < subscriptionIds.size(); i++) {
AUUID subId = (AUUID) subscriptionIds.getItem(i);
String subString = subId.toSimpleString();
JSON += "\"" + subString + "\"";
String subscriptionString = subId.toString();
//Broker code currently cannot handle the "uuid {}" part of the string, so we parse just the value
subscriptionString = subscriptionString.substring(8, subscriptionString.length() - 2);
JSON += "\"" + subscriptionString + "\"";
if (i < subscriptionIds.size() - 1) {
JSON += ",";
}
@@ -171,7 +171,7 @@ public byte getKind() {

private void createDatasets(IStatementExecutor statementExecutor, Identifier subscriptionsName,
Identifier resultsName, MetadataProvider metadataProvider, IHyracksClientConnection hcc,
IHyracksDataset hdc, Stats stats, String dataverse) throws AsterixException, Exception {
IHyracksDataset hdc, String dataverse) throws AsterixException, Exception {

Identifier subscriptionsTypeName = new Identifier(BADConstants.ChannelSubscriptionsType);
Identifier resultsTypeName = new Identifier(BADConstants.ChannelResultsType);
@@ -310,7 +310,7 @@ public void handle(IStatementExecutor statementExecutor, MetadataProvider metada
metadataProvider.getDefaultDataverse(), metadataProvider.getStorageComponentProvider());
tempMdProvider.setConfig(metadataProvider.getConfig());
//Create Channel Datasets
createDatasets(statementExecutor, subscriptionsName, resultsName, tempMdProvider, hcc, hdc, stats,
createDatasets(statementExecutor, subscriptionsName, resultsName, tempMdProvider, hcc, hdc,
dataverse);
tempMdProvider.getLocks().reset();
//Create Channel Internal Job
@@ -1,13 +1,13 @@
-- NOTIFY_BROKERS |PARTITIONED|
-- ONE_TO_ONE_EXCHANGE |PARTITIONED|
-- PRE_CLUSTERED_GROUP_BY[$$52, $$0] |PARTITIONED|
-- PRE_CLUSTERED_GROUP_BY[$$52, $$channelExecutionTime] |PARTITIONED|
{
-- AGGREGATE |LOCAL|
-- NESTED_TUPLE_SOURCE |LOCAL|
}
-- ONE_TO_ONE_EXCHANGE |PARTITIONED|
-- STABLE_SORT [$$52(ASC), $$0(ASC)] |PARTITIONED|
-- HASH_PARTITION_EXCHANGE [$$52, $$0] |PARTITIONED|
-- STABLE_SORT [$$52(ASC), $$channelExecutionTime(ASC)] |PARTITIONED|
-- HASH_PARTITION_EXCHANGE [$$52, $$channelExecutionTime] |PARTITIONED|
-- PRE_SORTED_DISTINCT_BY |PARTITIONED|
-- ONE_TO_ONE_EXCHANGE |PARTITIONED|
-- STABLE_SORT [$$37(ASC)] |PARTITIONED|
@@ -1,13 +1,13 @@
-- NOTIFY_BROKERS |PARTITIONED|
-- ONE_TO_ONE_EXCHANGE |PARTITIONED|
-- PRE_CLUSTERED_GROUP_BY[$$52, $$0] |PARTITIONED|
-- PRE_CLUSTERED_GROUP_BY[$$52, $$channelExecutionTime] |PARTITIONED|
{
-- AGGREGATE |LOCAL|
-- NESTED_TUPLE_SOURCE |LOCAL|
}
-- ONE_TO_ONE_EXCHANGE |PARTITIONED|
-- STABLE_SORT [$$52(ASC), $$0(ASC)] |PARTITIONED|
-- HASH_PARTITION_EXCHANGE [$$52, $$0] |PARTITIONED|
-- STABLE_SORT [$$52(ASC), $$channelExecutionTime(ASC)] |PARTITIONED|
-- HASH_PARTITION_EXCHANGE [$$52, $$channelExecutionTime] |PARTITIONED|
-- PRE_SORTED_DISTINCT_BY |PARTITIONED|
-- ONE_TO_ONE_EXCHANGE |PARTITIONED|
-- STABLE_SORT [$$37(ASC)] |PARTITIONED|
@@ -1,13 +1,13 @@
-- NOTIFY_BROKERS |PARTITIONED|
-- ONE_TO_ONE_EXCHANGE |PARTITIONED|
-- PRE_CLUSTERED_GROUP_BY[$$52, $$0] |PARTITIONED|
-- PRE_CLUSTERED_GROUP_BY[$$52, $$channelExecutionTime] |PARTITIONED|
{
-- AGGREGATE |LOCAL|
-- NESTED_TUPLE_SOURCE |LOCAL|
}
-- ONE_TO_ONE_EXCHANGE |PARTITIONED|
-- STABLE_SORT [$$52(ASC), $$0(ASC)] |PARTITIONED|
-- HASH_PARTITION_EXCHANGE [$$52, $$0] |PARTITIONED|
-- STABLE_SORT [$$52(ASC), $$channelExecutionTime(ASC)] |PARTITIONED|
-- HASH_PARTITION_EXCHANGE [$$52, $$channelExecutionTime] |PARTITIONED|
-- PRE_SORTED_DISTINCT_BY |PARTITIONED|
-- ONE_TO_ONE_EXCHANGE |PARTITIONED|
-- STABLE_SORT [$$37(ASC)] |PARTITIONED|

0 comments on commit dcbd6d1

Please sign in to comment.