Skip to content
Permalink
Browse files
Adapt to QueryTranslator Changes
- Pass additional parameter to Create/Drop dataset statemenets.

Change-Id: I75cb1b9a355e3fcdf257550569a0f07d36fd2fb1
  • Loading branch information
mhubail committed Oct 5, 2017
1 parent e9bf419 commit 2013598678bd205bde376d5e4bf5bafae39490c4
Show file tree
Hide file tree
Showing 2 changed files with 5 additions and 4 deletions.
@@ -124,11 +124,11 @@ public void handle(IHyracksClientConnection hcc, IStatementExecutor statementExe
//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);
@@ -198,9 +198,10 @@ private void createDatasets(IStatementExecutor statementExecutor, Identifier sub

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

}

0 comments on commit 2013598

Please sign in to comment.