You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by jk...@apache.org on 2017/04/19 01:12:31 UTC
[7/7] beam git commit: This closes #2556
This closes #2556
Project: http://git-wip-us.apache.org/repos/asf/beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/e0df7d85
Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/e0df7d85
Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/e0df7d85
Branch: refs/heads/master
Commit: e0df7d85e80eac71f875663512bc293a0529460f
Parents: a9bcc8b 6ac3ac5
Author: Eugene Kirpichov <ki...@google.com>
Authored: Tue Apr 18 18:02:25 2017 -0700
Committer: Eugene Kirpichov <ki...@google.com>
Committed: Tue Apr 18 18:02:25 2017 -0700
----------------------------------------------------------------------
.../operators/ApexParDoOperator.java | 3 +-
.../apache/beam/runners/core/DoFnRunners.java | 32 +++
.../beam/runners/core/ProcessFnRunner.java | 127 +++++++++
.../core/PushbackSideInputDoFnRunner.java | 106 +------
.../core/SimplePushbackSideInputDoFnRunner.java | 115 ++++++++
.../beam/runners/core/SplittableParDo.java | 110 +++++---
.../core/PushbackSideInputDoFnRunnerTest.java | 282 -------------------
.../SimplePushbackSideInputDoFnRunnerTest.java | 282 +++++++++++++++++++
.../beam/runners/core/SplittableParDoTest.java | 90 +++---
...ecycleManagerRemovingTransformEvaluator.java | 6 +-
.../beam/runners/direct/ParDoEvaluator.java | 127 ++++++---
.../runners/direct/ParDoEvaluatorFactory.java | 13 +-
...littableProcessElementsEvaluatorFactory.java | 106 +++++--
.../direct/StatefulParDoEvaluatorFactory.java | 4 +-
.../direct/TransformEvaluatorRegistry.java | 4 +-
...leManagerRemovingTransformEvaluatorTest.java | 8 +-
.../beam/runners/direct/ParDoEvaluatorTest.java | 7 +-
runners/flink/runner/pom.xml | 3 +-
.../wrappers/streaming/DoFnOperator.java | 12 +-
.../streaming/SplittableDoFnOperator.java | 2 +-
.../wrappers/streaming/WindowDoFnOperator.java | 2 +-
...esSplittableParDoWithWindowedSideInputs.java | 26 ++
.../beam/sdk/transforms/SplittableDoFnTest.java | 104 +++++--
23 files changed, 993 insertions(+), 578 deletions(-)
----------------------------------------------------------------------