This closes #1399
Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/33c68706 Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/33c68706 Diff: http://git-wip-us.apache.org/repos/asf/incubator-beam/diff/33c68706 Branch: refs/heads/master Commit: 33c687069adc1ce4481a0c9637b2a77abb9450b8 Parents: 5e9a80c ec2c0e0 Author: Kenneth Knowles <k...@google.com> Authored: Mon Nov 28 13:03:51 2016 -0800 Committer: Kenneth Knowles <k...@google.com> Committed: Mon Nov 28 13:03:51 2016 -0800 ---------------------------------------------------------------------- .../beam/runners/core/SimpleDoFnRunner.java | 60 +++- .../beam/runners/direct/EvaluationContext.java | 15 + .../beam/runners/direct/ParDoEvaluator.java | 17 +- .../runners/direct/ParDoEvaluatorFactory.java | 55 +++- .../direct/ParDoMultiOverrideFactory.java | 76 ++++- .../ParDoSingleViaMultiOverrideFactory.java | 6 +- .../direct/StatefulParDoEvaluatorFactory.java | 256 ++++++++++++++++ .../direct/TransformEvaluatorRegistry.java | 2 + .../direct/WatermarkCallbackExecutor.java | 34 +++ .../StatefulParDoEvaluatorFactoryTest.java | 300 +++++++++++++++++++ .../org/apache/beam/sdk/transforms/DoFn.java | 4 +- .../org/apache/beam/sdk/transforms/OldDoFn.java | 8 +- .../org/apache/beam/sdk/transforms/ParDo.java | 10 - .../sdk/transforms/reflect/DoFnSignature.java | 1 + .../apache/beam/sdk/transforms/ParDoTest.java | 177 ++++++++++- 15 files changed, 961 insertions(+), 60 deletions(-) ----------------------------------------------------------------------
