You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@asterixdb.apache.org by dl...@apache.org on 2019/07/10 00:15:07 UTC
[asterixdb-bad] branch master updated: [NO ISSUE][BAD] Instantiate
evaluators with IEvaluatorContext instead of IHyracksTaskContext
This is an automated email from the ASF dual-hosted git repository.
dlych pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/asterixdb-bad.git
The following commit(s) were added to refs/heads/master by this push:
new a96b02a [NO ISSUE][BAD] Instantiate evaluators with IEvaluatorContext instead of IHyracksTaskContext
a96b02a is described below
commit a96b02a6c7bdedd54c8b91d0c7c1001148fd8916
Author: Dmitry Lychagin <dm...@couchbase.com>
AuthorDate: Mon Jul 8 17:20:12 2019 -0700
[NO ISSUE][BAD] Instantiate evaluators with IEvaluatorContext instead of IHyracksTaskContext
Change-Id: I00bbf87a73bb380d95799c4c4a080a5380635a82
---
.../java/org/apache/asterix/bad/runtime/NotifyBrokerRuntime.java | 9 ++++++---
1 file changed, 6 insertions(+), 3 deletions(-)
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 5b9ae8f..ac742e8 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
@@ -46,8 +46,10 @@ import org.apache.asterix.om.types.ARecordType;
import org.apache.asterix.om.types.BuiltinType;
import org.apache.asterix.om.types.IAType;
import org.apache.hyracks.algebricks.data.IPrinter;
+import org.apache.hyracks.algebricks.runtime.base.IEvaluatorContext;
import org.apache.hyracks.algebricks.runtime.base.IScalarEvaluator;
import org.apache.hyracks.algebricks.runtime.base.IScalarEvaluatorFactory;
+import org.apache.hyracks.algebricks.runtime.evaluators.EvaluatorContext;
import org.apache.hyracks.algebricks.runtime.operators.base.AbstractOneInputOneOutputOneFramePushRuntime;
import org.apache.hyracks.api.context.IHyracksTaskContext;
import org.apache.hyracks.api.dataflow.value.RecordDescriptor;
@@ -90,9 +92,10 @@ public class NotifyBrokerRuntime extends AbstractOneInputOneOutputOneFramePushRu
IScalarEvaluatorFactory pushListEvalFactory, IScalarEvaluatorFactory channelExecutionEvalFactory,
EntityId activeJobId, boolean push, IAType recordType) throws HyracksDataException {
this.tRef = new FrameTupleReference();
- eval0 = brokerEvalFactory.createScalarEvaluator(ctx);
- eval1 = pushListEvalFactory.createScalarEvaluator(ctx);
- eval2 = channelExecutionEvalFactory.createScalarEvaluator(ctx);
+ IEvaluatorContext evalCtx = new EvaluatorContext(ctx);
+ eval0 = brokerEvalFactory.createScalarEvaluator(evalCtx);
+ eval1 = pushListEvalFactory.createScalarEvaluator(evalCtx);
+ eval2 = channelExecutionEvalFactory.createScalarEvaluator(evalCtx);
this.entityId = activeJobId;
this.push = push;
if (push) {