Repository: asterixdb-bad Updated Branches: refs/heads/master e9bf419e2 -> 201359867
Adapt to QueryTranslator Changes - Pass additional parameter to Create/Drop dataset statemenets. Change-Id: I75cb1b9a355e3fcdf257550569a0f07d36fd2fb1 Project: http://git-wip-us.apache.org/repos/asf/asterixdb-bad/repo Commit: http://git-wip-us.apache.org/repos/asf/asterixdb-bad/commit/20135986 Tree: http://git-wip-us.apache.org/repos/asf/asterixdb-bad/tree/20135986 Diff: http://git-wip-us.apache.org/repos/asf/asterixdb-bad/diff/20135986 Branch: refs/heads/master Commit: 2013598678bd205bde376d5e4bf5bafae39490c4 Parents: e9bf419 Author: Murtadha Hubail <[email protected]> Authored: Thu Oct 5 05:54:23 2017 +0300 Committer: Murtadha Hubail <[email protected]> Committed: Thu Oct 5 05:54:23 2017 +0300 ---------------------------------------------------------------------- .../apache/asterix/bad/lang/statement/ChannelDropStatement.java | 4 ++-- .../asterix/bad/lang/statement/CreateChannelStatement.java | 5 +++-- 2 files changed, 5 insertions(+), 4 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/asterixdb-bad/blob/20135986/asterix-bad/src/main/java/org/apache/asterix/bad/lang/statement/ChannelDropStatement.java ---------------------------------------------------------------------- diff --git a/asterix-bad/src/main/java/org/apache/asterix/bad/lang/statement/ChannelDropStatement.java b/asterix-bad/src/main/java/org/apache/asterix/bad/lang/statement/ChannelDropStatement.java index 43aa161..fb71770 100644 --- a/asterix-bad/src/main/java/org/apache/asterix/bad/lang/statement/ChannelDropStatement.java +++ b/asterix-bad/src/main/java/org/apache/asterix/bad/lang/statement/ChannelDropStatement.java @@ -124,11 +124,11 @@ public class ChannelDropStatement implements IExtensionStatement { //TODO: Prevent datasets for Channels from being dropped elsewhere DropDatasetStatement dropStmt = new DropDatasetStatement(new Identifier(dataverse), new Identifier(channel.getResultsDatasetName()), true); - ((QueryTranslator) statementExecutor).handleDatasetDropStatement(tempMdProvider, dropStmt, hcc); + ((QueryTranslator) statementExecutor).handleDatasetDropStatement(tempMdProvider, dropStmt, hcc, null); tempMdProvider.getLocks().reset(); dropStmt = new DropDatasetStatement(new Identifier(dataverse), new Identifier(channel.getSubscriptionsDataset()), true); - ((QueryTranslator) statementExecutor).handleDatasetDropStatement(tempMdProvider, dropStmt, hcc); + ((QueryTranslator) statementExecutor).handleDatasetDropStatement(tempMdProvider, dropStmt, hcc, null); //Remove the Channel Metadata MetadataManager.INSTANCE.deleteEntity(mdTxnCtx, channel); http://git-wip-us.apache.org/repos/asf/asterixdb-bad/blob/20135986/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 5c92cb5..a04ac49 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 @@ -198,9 +198,10 @@ public class CreateChannelStatement implements IExtensionStatement { //Run both statements to create datasets ((QueryTranslator) statementExecutor).handleCreateDatasetStatement(metadataProvider, createSubscriptionsDataset, - hcc); + hcc, null); metadataProvider.getLocks().reset(); - ((QueryTranslator) statementExecutor).handleCreateDatasetStatement(metadataProvider, createResultsDataset, hcc); + ((QueryTranslator) statementExecutor).handleCreateDatasetStatement(metadataProvider, createResultsDataset, hcc, + null); }
