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 2017/06/28 04:34:30 UTC
[6/6] beam git commit: This closes #3351: [BEAM-2371] Fix
getAdditionInputs for SplittableParDo transforms
This closes #3351: [BEAM-2371] Fix getAdditionInputs for SplittableParDo transforms
Use PCollectionViews.toAdditionalInputs in Combine
Use PCollectionViews.toAdditionalInputs in ParDo
Use PCollectionViews.toAdditionalInputs in ParDoMultiOverrideFactory
Fix getAdditionalInputs for SplittableParDo transforms
Add utility to expand list of PCollectionViews
Project: http://git-wip-us.apache.org/repos/asf/beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/16f8000e
Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/16f8000e
Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/16f8000e
Branch: refs/heads/master
Commit: 16f8000e24c5b56132987752b8e903392e5dd3e8
Parents: e5929bd 27674f0
Author: Kenneth Knowles <kl...@google.com>
Authored: Tue Jun 27 21:09:14 2017 -0700
Committer: Kenneth Knowles <kl...@google.com>
Committed: Tue Jun 27 21:09:14 2017 -0700
----------------------------------------------------------------------
.../apache/beam/runners/apex/ApexRunner.java | 2 +-
.../core/construction/SplittableParDo.java | 66 +++++++++++++++-----
.../core/construction/SplittableParDoTest.java | 8 +--
.../direct/ParDoMultiOverrideFactory.java | 16 ++---
.../flink/FlinkStreamingPipelineTranslator.java | 2 +-
.../dataflow/SplittableParDoOverrides.java | 2 +-
.../org/apache/beam/sdk/transforms/Combine.java | 13 +---
.../org/apache/beam/sdk/transforms/ParDo.java | 14 +----
.../beam/sdk/values/PCollectionViews.java | 14 +++++
9 files changed, 79 insertions(+), 58 deletions(-)
----------------------------------------------------------------------