You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@asterixdb.apache.org by sj...@apache.org on 2017/03/10 18:42:01 UTC
asterixdb-bad git commit: Fixed to work with AsterixDB changes
Repository: asterixdb-bad
Updated Branches:
refs/heads/master 936674a37 -> 5273c4f74
Fixed to work with AsterixDB changes
Change-Id: Ib91be596b0dc5907e463da1c074b0f0f2fde324d
Project: http://git-wip-us.apache.org/repos/asf/asterixdb-bad/repo
Commit: http://git-wip-us.apache.org/repos/asf/asterixdb-bad/commit/5273c4f7
Tree: http://git-wip-us.apache.org/repos/asf/asterixdb-bad/tree/5273c4f7
Diff: http://git-wip-us.apache.org/repos/asf/asterixdb-bad/diff/5273c4f7
Branch: refs/heads/master
Commit: 5273c4f74e8d9af9bf6a18c41b8ee9c7a061f70d
Parents: 936674a
Author: Steven Glenn Jacobs <sj...@ucr.edu>
Authored: Fri Mar 10 09:46:15 2017 -0800
Committer: Steven Glenn Jacobs <sj...@ucr.edu>
Committed: Fri Mar 10 09:46:15 2017 -0800
----------------------------------------------------------------------
.../org/apache/asterix/bad/metadata/BADMetadataExtension.java | 4 ++--
.../java/org/apache/asterix/bad/runtime/NotifyBrokerRuntime.java | 4 ++--
2 files changed, 4 insertions(+), 4 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/asterixdb-bad/blob/5273c4f7/asterix-bad/src/main/java/org/apache/asterix/bad/metadata/BADMetadataExtension.java
----------------------------------------------------------------------
diff --git a/asterix-bad/src/main/java/org/apache/asterix/bad/metadata/BADMetadataExtension.java b/asterix-bad/src/main/java/org/apache/asterix/bad/metadata/BADMetadataExtension.java
index 1a8eda1..cd4470f 100644
--- a/asterix-bad/src/main/java/org/apache/asterix/bad/metadata/BADMetadataExtension.java
+++ b/asterix-bad/src/main/java/org/apache/asterix/bad/metadata/BADMetadataExtension.java
@@ -37,7 +37,7 @@ import org.apache.asterix.metadata.entitytupletranslators.MetadataTupleTranslato
import org.apache.asterix.metadata.utils.MetadataUtil;
import org.apache.asterix.runtime.formats.NonTaggedDataFormat;
import org.apache.hyracks.algebricks.common.utils.Pair;
-import org.apache.hyracks.api.application.INCApplicationContext;
+import org.apache.hyracks.api.application.INCServiceContext;
import org.apache.hyracks.api.exceptions.HyracksDataException;
public class BADMetadataExtension implements IMetadataExtension {
@@ -89,7 +89,7 @@ public class BADMetadataExtension implements IMetadataExtension {
}
@Override
- public void initializeMetadata(INCApplicationContext appCtx)
+ public void initializeMetadata(INCServiceContext appCtx)
throws HyracksDataException, RemoteException, ACIDException {
// enlist datasets
MetadataBootstrap.enlistMetadataDataset(appCtx, BADMetadataIndexes.CHANNEL_DATASET);
http://git-wip-us.apache.org/repos/asf/asterixdb-bad/blob/5273c4f7/asterix-bad/src/main/java/org/apache/asterix/bad/runtime/NotifyBrokerRuntime.java
----------------------------------------------------------------------
diff --git a/asterix-bad/src/main/java/org/apache/asterix/bad/runtime/NotifyBrokerRuntime.java b/asterix-bad/src/main/java/org/apache/asterix/bad/runtime/NotifyBrokerRuntime.java
index 96b81d1..c5b7ef2 100644
--- a/asterix-bad/src/main/java/org/apache/asterix/bad/runtime/NotifyBrokerRuntime.java
+++ b/asterix-bad/src/main/java/org/apache/asterix/bad/runtime/NotifyBrokerRuntime.java
@@ -70,8 +70,8 @@ public class NotifyBrokerRuntime extends AbstractOneInputOneOutputOneFramePushRu
eval0 = brokerEvalFactory.createScalarEvaluator(ctx);
eval1 = subEvalFactory.createScalarEvaluator(ctx);
eval2 = channelExecutionEvalFactory.createScalarEvaluator(ctx);
- this.activeManager = (ActiveManager) ((IAppRuntimeContext) ctx.getJobletContext().getApplicationContext()
- .getApplicationObject()).getActiveManager();
+ this.activeManager = (ActiveManager) ((IAppRuntimeContext) ctx.getJobletContext().getServiceContext()
+ .getApplicationContext()).getActiveManager();
this.entityId = activeJobId;
}