Remove extraneous ExecutionContext parameter to BaseStepContext
Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/248c808a Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/248c808a Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/248c808a Branch: refs/heads/master Commit: 248c808a6603dc2c28a0b55296e0d596b8903a08 Parents: 59322d5 Author: Kenneth Knowles <[email protected]> Authored: Mon May 22 15:36:41 2017 -0700 Committer: Kenneth Knowles <[email protected]> Committed: Tue May 23 11:16:27 2017 -0700 ---------------------------------------------------------------------- .../main/java/org/apache/beam/runners/core/BaseStepContext.java | 4 +--- .../org/apache/beam/runners/direct/DirectExecutionContext.java | 2 +- 2 files changed, 2 insertions(+), 4 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/beam/blob/248c808a/runners/core-java/src/main/java/org/apache/beam/runners/core/BaseStepContext.java ---------------------------------------------------------------------- diff --git a/runners/core-java/src/main/java/org/apache/beam/runners/core/BaseStepContext.java b/runners/core-java/src/main/java/org/apache/beam/runners/core/BaseStepContext.java index f0436ac..014fe0d 100644 --- a/runners/core-java/src/main/java/org/apache/beam/runners/core/BaseStepContext.java +++ b/runners/core-java/src/main/java/org/apache/beam/runners/core/BaseStepContext.java @@ -30,12 +30,10 @@ import org.apache.beam.sdk.values.TupleTag; * {@link #stateInternals}. */ public abstract class BaseStepContext implements StepContext { - private final ExecutionContext executionContext; private final String stepName; private final String transformName; - public BaseStepContext(ExecutionContext executionContext, String stepName, String transformName) { - this.executionContext = executionContext; + public BaseStepContext(String stepName, String transformName) { this.stepName = stepName; this.transformName = transformName; } http://git-wip-us.apache.org/repos/asf/beam/blob/248c808a/runners/direct-java/src/main/java/org/apache/beam/runners/direct/DirectExecutionContext.java ---------------------------------------------------------------------- diff --git a/runners/direct-java/src/main/java/org/apache/beam/runners/direct/DirectExecutionContext.java b/runners/direct-java/src/main/java/org/apache/beam/runners/direct/DirectExecutionContext.java index e5b88e5..d676f24 100644 --- a/runners/direct-java/src/main/java/org/apache/beam/runners/direct/DirectExecutionContext.java +++ b/runners/direct-java/src/main/java/org/apache/beam/runners/direct/DirectExecutionContext.java @@ -64,7 +64,7 @@ class DirectExecutionContext public DirectStepContext( ExecutionContext executionContext, String stepName, String transformName) { - super(executionContext, stepName, transformName); + super(stepName, transformName); } @Override
