You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@asterixdb.apache.org by mb...@apache.org on 2021/01/13 19:36:40 UTC
[asterixdb] 01/06: [NO ISSUE] Refactoring for extension
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 <al...@gmail.com>
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 <je...@fulliautomatix.ics.uci.edu>
Tested-by: Jenkins <je...@fulliautomatix.ics.uci.edu>
Reviewed-by: Michael Blow <mb...@apache.org>
---
.../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();
+ }
}
}