This is an automated email from the ASF dual-hosted git repository. mblow pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/asterixdb.git
commit 49350fdec8202157336279d72e2a6428df169286 Author: Ali Alsuliman <[email protected]> AuthorDate: Wed Dec 23 10:54:36 2020 -0800 [NO ISSUE] Refactoring for extension Change-Id: I49e4754b1c329c78b85925ca8af6837512cb15e8 Reviewed-on: https://asterix-gerrit.ics.uci.edu/c/asterixdb/+/9445 Integration-Tests: Jenkins <[email protected]> Tested-by: Jenkins <[email protected]> Reviewed-by: Michael Blow <[email protected]> --- .../hyracks/algebricks/runtime/evaluators/EvaluatorContext.java | 6 ++++++ .../runtime/operators/std/StreamSelectRuntimeFactory.java | 7 ++++++- 2 files changed, 12 insertions(+), 1 deletion(-) diff --git a/hyracks-fullstack/algebricks/algebricks-runtime/src/main/java/org/apache/hyracks/algebricks/runtime/evaluators/EvaluatorContext.java b/hyracks-fullstack/algebricks/algebricks-runtime/src/main/java/org/apache/hyracks/algebricks/runtime/evaluators/EvaluatorContext.java index 8d31f6b..901e788 100644 --- a/hyracks-fullstack/algebricks/algebricks-runtime/src/main/java/org/apache/hyracks/algebricks/runtime/evaluators/EvaluatorContext.java +++ b/hyracks-fullstack/algebricks/algebricks-runtime/src/main/java/org/apache/hyracks/algebricks/runtime/evaluators/EvaluatorContext.java @@ -46,6 +46,12 @@ public final class EvaluatorContext implements IEvaluatorContext { this.warningCollector = Objects.requireNonNull(warningCollector); } + public EvaluatorContext(IHyracksTaskContext taskContext, IWarningCollector warningCollector) { + this.taskContext = Objects.requireNonNull(taskContext); + this.serviceContext = Objects.requireNonNull(taskContext.getJobletContext().getServiceContext()); + this.warningCollector = Objects.requireNonNull(warningCollector); + } + @Override public IServiceContext getServiceContext() { return serviceContext; diff --git a/hyracks-fullstack/algebricks/algebricks-runtime/src/main/java/org/apache/hyracks/algebricks/runtime/operators/std/StreamSelectRuntimeFactory.java b/hyracks-fullstack/algebricks/algebricks-runtime/src/main/java/org/apache/hyracks/algebricks/runtime/operators/std/StreamSelectRuntimeFactory.java index acdc449..5cfebc0 100644 --- a/hyracks-fullstack/algebricks/algebricks-runtime/src/main/java/org/apache/hyracks/algebricks/runtime/operators/std/StreamSelectRuntimeFactory.java +++ b/hyracks-fullstack/algebricks/algebricks-runtime/src/main/java/org/apache/hyracks/algebricks/runtime/operators/std/StreamSelectRuntimeFactory.java @@ -34,6 +34,7 @@ import org.apache.hyracks.api.context.IHyracksTaskContext; import org.apache.hyracks.api.dataflow.value.IMissingWriter; import org.apache.hyracks.api.dataflow.value.IMissingWriterFactory; import org.apache.hyracks.api.exceptions.HyracksDataException; +import org.apache.hyracks.api.exceptions.IWarningCollector; import org.apache.hyracks.data.std.api.IPointable; import org.apache.hyracks.data.std.primitive.VoidPointable; import org.apache.hyracks.dataflow.common.comm.io.ArrayTupleBuilder; @@ -110,7 +111,7 @@ public class StreamSelectRuntimeFactory extends AbstractOneInputOneOutputRuntime protected ArrayTupleBuilder missingTupleBuilder; public StreamSelectRuntime(IHyracksTaskContext ctx, IBinaryBooleanInspector bbi) { - this.ctx = new EvaluatorContext(ctx); + this.ctx = new EvaluatorContext(ctx, initWarningCollector(ctx)); this.bbi = bbi; } @@ -165,6 +166,10 @@ public class StreamSelectRuntimeFactory extends AbstractOneInputOneOutputRuntime } } } + + protected IWarningCollector initWarningCollector(IHyracksTaskContext ctx) { + return ctx.getWarningCollector(); + } } }
