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/gearpump-runner Commit: 16f8000e24c5b56132987752b8e903392e5dd3e8 Parents: e5929bd 27674f0 Author: Kenneth Knowles <[email protected]> Authored: Tue Jun 27 21:09:14 2017 -0700 Committer: Kenneth Knowles <[email protected]> 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(-) ----------------------------------------------------------------------
