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/DSL_SQL Commit: e0df7d85e80eac71f875663512bc293a0529460f Parents: a9bcc8b 6ac3ac5 Author: Eugene Kirpichov <kirpic...@google.com> Authored: Tue Apr 18 18:02:25 2017 -0700 Committer: Eugene Kirpichov <kirpic...@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(-) ----------------------------------------------------------------------