You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by th...@apache.org on 2016/10/25 16:28:24 UTC
[06/50] incubator-beam git commit: Switch the DirectRunner to use new
DoFnRunner code path
Switch the DirectRunner to use new DoFnRunner code path
This does not yet switch to run new DoFn directly, but
to use the generic DoFnRunner dispatch in preparation
for switching over to the original DoFn instead of the
wrapper as an OldDoFn.
Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/52264612
Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/52264612
Diff: http://git-wip-us.apache.org/repos/asf/incubator-beam/diff/52264612
Branch: refs/heads/apex-runner
Commit: 522646122f43b2ae502f45f8c97859a7660cc86f
Parents: 0db3263
Author: Kenneth Knowles <kl...@google.com>
Authored: Wed Oct 19 21:31:25 2016 -0700
Committer: Kenneth Knowles <kl...@google.com>
Committed: Thu Oct 20 18:33:00 2016 -0700
----------------------------------------------------------------------
.../main/java/org/apache/beam/runners/direct/ParDoEvaluator.java | 3 +--
1 file changed, 1 insertion(+), 2 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-beam/blob/52264612/runners/direct-java/src/main/java/org/apache/beam/runners/direct/ParDoEvaluator.java
----------------------------------------------------------------------
diff --git a/runners/direct-java/src/main/java/org/apache/beam/runners/direct/ParDoEvaluator.java b/runners/direct-java/src/main/java/org/apache/beam/runners/direct/ParDoEvaluator.java
index bbe7827..a59fb4d 100644
--- a/runners/direct-java/src/main/java/org/apache/beam/runners/direct/ParDoEvaluator.java
+++ b/runners/direct-java/src/main/java/org/apache/beam/runners/direct/ParDoEvaluator.java
@@ -31,7 +31,6 @@ import org.apache.beam.runners.direct.DirectExecutionContext.DirectStepContext;
import org.apache.beam.runners.direct.DirectRunner.CommittedBundle;
import org.apache.beam.runners.direct.DirectRunner.UncommittedBundle;
import org.apache.beam.sdk.transforms.AppliedPTransform;
-import org.apache.beam.sdk.transforms.OldDoFn;
import org.apache.beam.sdk.util.ReadyCheckingSideInputReader;
import org.apache.beam.sdk.util.UserCodeException;
import org.apache.beam.sdk.util.WindowedValue;
@@ -46,7 +45,7 @@ class ParDoEvaluator<T> implements TransformEvaluator<T> {
DirectStepContext stepContext,
CommittedBundle<InputT> inputBundle,
AppliedPTransform<PCollection<InputT>, ?, ?> application,
- OldDoFn<InputT, OutputT> fn,
+ Object fn,
List<PCollectionView<?>> sideInputs,
TupleTag<OutputT> mainOutputTag,
List<TupleTag<?>> sideOutputTags,