beam-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From k...@apache.org
Subject [14/50] beam git commit: This closes #3351: [BEAM-2371] Fix getAdditionInputs for SplittableParDo transforms
Date Fri, 30 Jun 2017 21:31:16 GMT
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 <klk@google.com>
Authored: Tue Jun 27 21:09:14 2017 -0700
Committer: Kenneth Knowles <klk@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(-)
----------------------------------------------------------------------



Mime
View raw message