You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by ke...@apache.org on 2016/11/23 06:52:10 UTC
[14/50] incubator-beam git commit: This closes #1378
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 <kl...@google.com>
Authored: Fri Nov 18 15:09:43 2016 -0800
Committer: Kenneth Knowles <kl...@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(-)
----------------------------------------------------------------------