Change in asterixdb-bad[master]: Adapt to QueryTranslator Changes

[Murtadha Hubail (Code Review)]

Murtadha Hubail has submitted this change and it was merged.

Change subject: Adapt to QueryTranslator Changes
......................................................................


Adapt to QueryTranslator Changes

- Pass additional parameter to Create/Drop dataset statemenets.

Change-Id: I75cb1b9a355e3fcdf257550569a0f07d36fd2fb1
---
M 
asterix-bad/src/main/java/org/apache/asterix/bad/lang/statement/ChannelDropStatement.java
M 
asterix-bad/src/main/java/org/apache/asterix/bad/lang/statement/CreateChannelStatement.java
2 files changed, 5 insertions(+), 4 deletions(-)

Approvals:
  Till Westmann: Looks good to me, approved
  Jenkins: Verified



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 @@
             //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);
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 @@
 
         //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);
 
     }
 

-- 
To view, visit https://asterix-gerrit.ics.uci.edu/2054
To unsubscribe, visit https://asterix-gerrit.ics.uci.edu/settings

Gerrit-MessageType: merged
Gerrit-Change-Id: I75cb1b9a355e3fcdf257550569a0f07d36fd2fb1
Gerrit-PatchSet: 1
Gerrit-Project: asterixdb-bad
Gerrit-Branch: master
Gerrit-Owner: Murtadha Hubail <mhub...@apache.org>
Gerrit-Reviewer: Jenkins <jenk...@fulliautomatix.ics.uci.edu>
Gerrit-Reviewer: Murtadha Hubail <mhub...@apache.org>
Gerrit-Reviewer: Till Westmann <ti...@apache.org>