Skip to content
Permalink
Browse files
Fixed to work with AsterixDB changes
Change-Id: Ib91be596b0dc5907e463da1c074b0f0f2fde324d
  • Loading branch information
sjaco002 committed Mar 10, 2017
1 parent 936674a commit 5273c4f74e8d9af9bf6a18c41b8ee9c7a061f70d
Showing 2 changed files with 4 additions and 4 deletions.
@@ -37,7 +37,7 @@
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 List<ExtensionMetadataDataset> getExtensionIndexes() {
}

@Override
public void initializeMetadata(INCApplicationContext appCtx)
public void initializeMetadata(INCServiceContext appCtx)
throws HyracksDataException, RemoteException, ACIDException {
// enlist datasets
MetadataBootstrap.enlistMetadataDataset(appCtx, BADMetadataIndexes.CHANNEL_DATASET);
@@ -70,8 +70,8 @@ public NotifyBrokerRuntime(IHyracksTaskContext ctx, IScalarEvaluatorFactory brok
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;
}

0 comments on commit 5273c4f

Please sign in to comment.