Steven Jacobs has uploaded a new change for review.
https://asterix-gerrit.ics.uci.edu/1573
Change subject: Match Master method changes
......................................................................
Match Master method changes
Change-Id: Ib3298247ac09ce5f92a9c174438bd76d7a4d319e
---
M
asterix-bad/src/main/java/org/apache/asterix/bad/lang/statement/ChannelSubscribeStatement.java
M
asterix-bad/src/main/java/org/apache/asterix/bad/lang/statement/CreateChannelStatement.java
M
asterix-bad/src/main/java/org/apache/asterix/bad/lang/statement/CreateProcedureStatement.java
3 files changed, 5 insertions(+), 4 deletions(-)
git pull ssh://asterix-gerrit.ics.uci.edu:29418/asterixdb-bad
refs/changes/73/1573/1
diff --git
a/asterix-bad/src/main/java/org/apache/asterix/bad/lang/statement/ChannelSubscribeStatement.java
b/asterix-bad/src/main/java/org/apache/asterix/bad/lang/statement/ChannelSubscribeStatement.java
index 4ba9fb5..bb3cef2 100644
---
a/asterix-bad/src/main/java/org/apache/asterix/bad/lang/statement/ChannelSubscribeStatement.java
+++
b/asterix-bad/src/main/java/org/apache/asterix/bad/lang/statement/ChannelSubscribeStatement.java
@@ -210,12 +210,12 @@
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);
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 7c6aa19..a5e9c7c 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
@@ -231,7 +231,7 @@
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,
diff --git
a/asterix-bad/src/main/java/org/apache/asterix/bad/lang/statement/CreateProcedureStatement.java
b/asterix-bad/src/main/java/org/apache/asterix/bad/lang/statement/CreateProcedureStatement.java
index a98d780..7a1bc54 100644
---
a/asterix-bad/src/main/java/org/apache/asterix/bad/lang/statement/CreateProcedureStatement.java
+++
b/asterix-bad/src/main/java/org/apache/asterix/bad/lang/statement/CreateProcedureStatement.java
@@ -154,7 +154,8 @@
}
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);
--
To view, visit https://asterix-gerrit.ics.uci.edu/1573
To unsubscribe, visit https://asterix-gerrit.ics.uci.edu/settings
Gerrit-MessageType: newchange
Gerrit-Change-Id: Ib3298247ac09ce5f92a9c174438bd76d7a4d319e
Gerrit-PatchSet: 1
Gerrit-Project: asterixdb-bad
Gerrit-Branch: master
Gerrit-Owner: Steven Jacobs <sjaco...@ucr.edu>
