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/06/23 01:48:56 UTC
[3/3] beam git commit: This closes #3417: [BEAM-1377] Uses KV in
SplittableParDo expansion instead of ElementAndRestriction
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/master
Commit: 8860cceb710f28931fe5ec792b0db09277f0d2a9
Parents: 7a9f762 799173f
Author: Eugene Kirpichov <ki...@google.com>
Authored: Thu Jun 22 17:56:44 2017 -0700
Committer: Eugene Kirpichov <ki...@google.com>
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(-)
----------------------------------------------------------------------