This closes #1141
Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/15335112 Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/15335112 Diff: http://git-wip-us.apache.org/repos/asf/incubator-beam/diff/15335112 Branch: refs/heads/master Commit: 153351126357da91d7adeab8339025914e18920c Parents: 465c7d1 5226461 Author: Kenneth Knowles <[email protected]> Authored: Thu Oct 20 19:52:50 2016 -0700 Committer: Kenneth Knowles <[email protected]> Committed: Thu Oct 20 19:52:50 2016 -0700 ---------------------------------------------------------------------- .../apache/beam/runners/core/DoFnRunners.java | 189 +++++-- .../beam/runners/core/SimpleDoFnRunner.java | 337 +++++++----- .../beam/runners/core/SimpleOldDoFnRunner.java | 521 +++++++++++++++++++ .../beam/runners/core/SimpleDoFnRunnerTest.java | 88 ---- .../runners/core/SimpleOldDoFnRunnerTest.java | 88 ++++ .../beam/runners/direct/ParDoEvaluator.java | 3 +- .../org/apache/beam/sdk/transforms/OldDoFn.java | 183 +++++++ .../org/apache/beam/sdk/transforms/ParDo.java | 248 +++++---- 8 files changed, 1299 insertions(+), 358 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-beam/blob/15335112/runners/core-java/src/main/java/org/apache/beam/runners/core/DoFnRunners.java ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-beam/blob/15335112/sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/OldDoFn.java ----------------------------------------------------------------------
