Skip to content
Permalink
Browse files
Update AsterixDB and Hyracks versions
Change-Id: I2cca9cbf893465e358b220bc6e2a3af2bd631575
  • Loading branch information
amoudi87 committed Aug 28, 2017
1 parent e3cd0f6 commit d5ef650f9d29bf8d05ea5912a2b3704108fc73ec
Showing 6 changed files with 8 additions and 8 deletions.
@@ -25,8 +25,8 @@
</parent>
<artifactId>asterix-bad</artifactId>
<properties>
<asterix.version>0.9.2-SNAPSHOT</asterix.version>
<hyracks.version>0.3.2-SNAPSHOT</hyracks.version>
<asterix.version>0.9.3-SNAPSHOT</asterix.version>
<hyracks.version>0.3.3-SNAPSHOT</hyracks.version>
</properties>
<build>
<plugins>
@@ -207,13 +207,13 @@ public void handle(IStatementExecutor statementExecutor, MetadataProvider metada
InsertStatement insert = new InsertStatement(new Identifier(dataverse),
new Identifier(subscriptionsDatasetName), subscriptionTuple, varCounter, resultVar, accessor);
((QueryTranslator) statementExecutor).handleInsertUpsertStatement(tempMdProvider, insert, hcc, hdc,
resultDelivery, null, stats, false, null, null);
resultDelivery, null, stats, false, null);
} else {
//To update an existing subscription
UpsertStatement upsert = new UpsertStatement(new Identifier(dataverse),
new Identifier(subscriptionsDatasetName), subscriptionTuple, varCounter, null, null);
((QueryTranslator) statementExecutor).handleInsertUpsertStatement(tempMdProvider, upsert, hcc, hdc,
resultDelivery, null, stats, false, null, null);
resultDelivery, null, stats, false, null);
}

MetadataManager.INSTANCE.commitTransaction(mdTxnCtx);
@@ -234,7 +234,7 @@ private JobSpecification createChannelJob(IStatementExecutor statementExecutor,
metadataProvider.getConfig().put(ss.getPropName(), ss.getPropValue());

return ((QueryTranslator) statementExecutor).handleInsertUpsertStatement(metadataProvider, fStatements.get(1),
hcc, hdc, ResultDelivery.ASYNC, null, stats, true, null, null);
hcc, hdc, ResultDelivery.ASYNC, null, stats, true, null);
}

private void setupExecutorJob(EntityId entityId, JobSpecification channeljobSpec, IHyracksClientConnection hcc,
@@ -171,7 +171,7 @@ 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, null, stats, true, null, null),
fStatements.get(0), hcc, hdc, ResultDelivery.ASYNC, null, stats, true, null),
PrecompiledType.INSERT);
} else if (fStatements.get(0).getKind() == Statement.Kind.QUERY) {
Pair<JobSpecification, PrecompiledType> pair =
@@ -30,7 +30,7 @@
<!-- project coordinates -->
<groupId>org.apache.asterix</groupId>
<artifactId>asterix-opt-bom</artifactId>
<version>0.9.2-SNAPSHOT</version>
<version>0.9.3-SNAPSHOT</version>
<packaging>pom</packaging>
<name>asterix-opt-bom</name>
<description>BAD Extension to AsterixDB</description>
@@ -25,7 +25,7 @@
<parent>
<groupId>org.apache.asterix</groupId>
<artifactId>apache-asterixdb</artifactId>
<version>0.9.2-SNAPSHOT</version>
<version>0.9.3-SNAPSHOT</version>
</parent>
<modules>
<module>asterix-bad</module>

0 comments on commit d5ef650

Please sign in to comment.