Repository: asterixdb-bad Updated Branches: refs/heads/master 939d790f7 -> 6bac49817
Coordinated change to change merge policy syntax Change-Id: Ie4a36562c98d2b5aa03d1601fa54d980a79ce7b9 Project: http://git-wip-us.apache.org/repos/asf/asterixdb-bad/repo Commit: http://git-wip-us.apache.org/repos/asf/asterixdb-bad/commit/6bac4981 Tree: http://git-wip-us.apache.org/repos/asf/asterixdb-bad/tree/6bac4981 Diff: http://git-wip-us.apache.org/repos/asf/asterixdb-bad/diff/6bac4981 Branch: refs/heads/master Commit: 6bac498177a7bf732379f179145ca4c0fc5d90f9 Parents: 939d790 Author: Steven Glenn Jacobs <[email protected]> Authored: Wed Nov 29 10:15:01 2017 -0800 Committer: Steven Glenn Jacobs <[email protected]> Committed: Wed Nov 29 10:15:01 2017 -0800 ---------------------------------------------------------------------- .../asterix/bad/lang/statement/CreateChannelStatement.java | 8 ++++---- 1 file changed, 4 insertions(+), 4 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/asterixdb-bad/blob/6bac4981/asterix-bad/src/main/java/org/apache/asterix/bad/lang/statement/CreateChannelStatement.java ---------------------------------------------------------------------- diff --git a/asterix-bad/src/main/java/org/apache/asterix/bad/lang/statement/CreateChannelStatement.java b/asterix-bad/src/main/java/org/apache/asterix/bad/lang/statement/CreateChannelStatement.java index 2a2ae54..3864248 100644 --- a/asterix-bad/src/main/java/org/apache/asterix/bad/lang/statement/CreateChannelStatement.java +++ b/asterix-bad/src/main/java/org/apache/asterix/bad/lang/statement/CreateChannelStatement.java @@ -184,8 +184,8 @@ public class CreateChannelStatement implements IExtensionStatement { partitionFields.add(fieldNames); IDatasetDetailsDecl idd = new InternalDetailsDecl(partitionFields, keyIndicators, true, null); DatasetDecl createSubscriptionsDataset = new DatasetDecl(new Identifier(dataverse), subscriptionsName, - new Identifier(BADConstants.BAD_DATAVERSE_NAME), subscriptionsTypeName, null, null, null, null, - new HashMap<String, String>(), new HashMap<String, String>(), DatasetType.INTERNAL, idd, true); + new Identifier(BADConstants.BAD_DATAVERSE_NAME), subscriptionsTypeName, null, null, null, + new HashMap<String, String>(), DatasetType.INTERNAL, idd, null, true); //Setup the results dataset partitionFields = new ArrayList<>(); @@ -194,8 +194,8 @@ public class CreateChannelStatement implements IExtensionStatement { partitionFields.add(fieldNames); idd = new InternalDetailsDecl(partitionFields, keyIndicators, true, null); DatasetDecl createResultsDataset = new DatasetDecl(new Identifier(dataverse), resultsName, - new Identifier(BADConstants.BAD_DATAVERSE_NAME), resultsTypeName, null, null, null, null, - new HashMap<String, String>(), new HashMap<String, String>(), DatasetType.INTERNAL, idd, true); + new Identifier(BADConstants.BAD_DATAVERSE_NAME), resultsTypeName, null, null, null, + new HashMap<String, String>(), DatasetType.INTERNAL, idd, null, true); //Create an index on timestamp for results CreateIndexStatement createTimeIndex = new CreateIndexStatement();
