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/master Commit: 522646122f43b2ae502f45f8c97859a7660cc86f Parents: 0db3263 Author: Kenneth Knowles <[email protected]> Authored: Wed Oct 19 21:31:25 2016 -0700 Committer: Kenneth Knowles <[email protected]> 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,
