This closes #1378
Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/d93e9a88 Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/d93e9a88 Diff: http://git-wip-us.apache.org/repos/asf/incubator-beam/diff/d93e9a88 Branch: refs/heads/gearpump-runner Commit: d93e9a88b0f0b3c7dc2461cbd11147b9ad8327cf Parents: 3548ffb f86e98c Author: Kenneth Knowles <k...@google.com> Authored: Fri Nov 18 15:09:43 2016 -0800 Committer: Kenneth Knowles <k...@google.com> Committed: Fri Nov 18 15:09:43 2016 -0800 ---------------------------------------------------------------------- .../beam/runners/direct/DirectRunner.java | 3 +- .../runners/direct/ParDoEvaluatorFactory.java | 56 +-- .../direct/ParDoMultiEvaluatorHooks.java | 55 --- .../direct/ParDoMultiOverrideFactory.java | 51 +++ .../runners/direct/ParDoOverrideFactory.java | 53 --- .../direct/ParDoSingleEvaluatorHooks.java | 58 --- .../ParDoSingleViaMultiOverrideFactory.java | 66 +++ .../direct/TransformEvaluatorRegistry.java | 7 +- .../direct/ParDoMultiEvaluatorHooksTest.java | 439 ------------------- .../direct/ParDoSingleEvaluatorHooksTest.java | 335 -------------- .../org/apache/beam/sdk/transforms/DoFn.java | 7 +- .../beam/sdk/transforms/DoFnAdapters.java | 6 + .../org/apache/beam/sdk/transforms/OldDoFn.java | 7 +- .../org/apache/beam/sdk/transforms/ParDo.java | 2 +- .../beam/sdk/transforms/WithTimestamps.java | 5 +- .../apache/beam/sdk/transforms/OldDoFnTest.java | 11 +- .../apache/beam/sdk/transforms/ParDoTest.java | 55 ++- 17 files changed, 194 insertions(+), 1022 deletions(-) ----------------------------------------------------------------------