Skip to content
Permalink
Browse files
Match Master method changes
Change-Id: Ib3298247ac09ce5f92a9c174438bd76d7a4d319e
  • Loading branch information
sjaco002 committed Mar 13, 2017
1 parent 5273c4f commit 607ee5ff56c204221e891610431bac09ec480cf5
Showing 3 changed files with 5 additions and 4 deletions.
@@ -210,12 +210,12 @@ public void handle(IStatementExecutor statementExecutor, MetadataProvider metada
new Identifier(subscriptionsDatasetName), subscriptionTuple, varCounter, resultVar,
body);
((QueryTranslator) statementExecutor).handleInsertUpsertStatement(metadataProvider, insert, hcc, hdc,
resultDelivery, stats, false);
resultDelivery, stats, false, null, null);
} else {
UpsertStatement upsert = new UpsertStatement(new Identifier(dataverse),
new Identifier(subscriptionsDatasetName), subscriptionTuple, varCounter, null, null);
((QueryTranslator) statementExecutor).handleInsertUpsertStatement(metadataProvider, upsert, hcc, hdc,
resultDelivery, stats, false);
resultDelivery, stats, false, null, null);
}

MetadataManager.INSTANCE.commitTransaction(mdTxnCtx);
@@ -231,7 +231,7 @@ private JobSpecification createChannelJob(IStatementExecutor statementExecutor,
AQLParserFactory aqlFact = new AQLParserFactory();
List<Statement> fStatements = aqlFact.createParser(new StringReader(builder.toString())).parse();
return ((QueryTranslator) statementExecutor).handleInsertUpsertStatement(metadataProvider, fStatements.get(0),
hcc, hdc, ResultDelivery.ASYNC, stats, true);
hcc, hdc, ResultDelivery.ASYNC, stats, true, null, null);
}

private void setupExecutorJob(EntityId entityId, JobSpecification channeljobSpec, IHyracksClientConnection hcc,
@@ -154,7 +154,8 @@ private Pair<JobSpecification, PrecompiledType> createProcedureJob(String body,
}
if (fStatements.get(0).getKind() == Statement.Kind.INSERT) {
return new Pair<>(((QueryTranslator) statementExecutor).handleInsertUpsertStatement(metadataProvider,
fStatements.get(0), hcc, hdc, ResultDelivery.ASYNC, stats, true), PrecompiledType.INSERT);
fStatements.get(0), hcc, hdc, ResultDelivery.ASYNC, stats, true, null, null),
PrecompiledType.INSERT);
} else if (fStatements.get(0).getKind() == Statement.Kind.QUERY) {
return new Pair<>(((QueryTranslator) statementExecutor).rewriteCompileQuery(hcc, metadataProvider,
(Query) fStatements.get(0), null), PrecompiledType.QUERY);

0 comments on commit 607ee5f

Please sign in to comment.