This closes #3417: [BEAM-1377] Uses KV in SplittableParDo expansion instead of ElementAndRestriction
Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/8860cceb Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/8860cceb Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/8860cceb Branch: refs/heads/gearpump-runner Commit: 8860cceb710f28931fe5ec792b0db09277f0d2a9 Parents: 7a9f762 799173f Author: Eugene Kirpichov <[email protected]> Authored: Thu Jun 22 17:56:44 2017 -0700 Committer: Eugene Kirpichov <[email protected]> Committed: Thu Jun 22 17:56:44 2017 -0700 ---------------------------------------------------------------------- .../construction/ElementAndRestriction.java | 42 ------- .../ElementAndRestrictionCoder.java | 88 ------------- .../core/construction/SplittableParDo.java | 39 +++--- .../ElementAndRestrictionCoderTest.java | 126 ------------------- .../beam/runners/core/ProcessFnRunner.java | 16 +-- .../core/SplittableParDoViaKeyedWorkItems.java | 49 ++++---- .../core/SplittableParDoProcessFnTest.java | 16 +-- ...littableProcessElementsEvaluatorFactory.java | 37 +++--- .../FlinkStreamingTransformTranslators.java | 19 +-- .../streaming/SplittableDoFnOperator.java | 16 +-- runners/google-cloud-dataflow-java/pom.xml | 2 +- 11 files changed, 78 insertions(+), 372 deletions(-) ----------------------------------------------------------------------
