You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by lc...@apache.org on 2018/04/09 18:37:28 UTC
[beam] branch master updated (d457df7 -> c22e1b4)
This is an automated email from the ASF dual-hosted git repository.
lcwik pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git.
from d457df7 [BEAM-4014] Remove previous names because this renames the existing job which is a different type of job.
add cca7a20 [BEAM-3706] Removing SideInputs and Parameters from CombinePayload.
add cca63ee [BEAM-3706] Removing side inputs from Combine translation logic.
add 079b1a4 [BEAM-3706] Attempting to fix a findbug issue.
add e025bff [BEAM-3706] Cleaning up side input code in Flink runner.
add 945c3ef [BEAM-3706] Fixing issue in direct runner with side input combines.
new c22e1b4 [BEAM-3706] Removing side inputs from CombinePayload proto.
The 1 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
.../pipeline/src/main/proto/beam_runner_api.proto | 9 --
.../core/construction/CombineTranslation.java | 132 +++++++--------------
.../core/construction/PTransformTranslation.java | 8 +-
.../core/construction/CombineTranslationTest.java | 46 ++++++-
.../beam/runners/direct/MultiStepCombine.java | 15 ++-
.../flink/FlinkBatchTransformTranslators.java | 30 +----
.../flink/FlinkStreamingTransformTranslators.java | 127 ++++----------------
.../functions/FlinkPartialReduceFunction.java | 1 +
.../translation/functions/FlinkReduceFunction.java | 1 +
9 files changed, 131 insertions(+), 238 deletions(-)
--
To stop receiving notification emails like this one, please contact
lcwik@apache.org.
[beam] 01/01: [BEAM-3706] Removing side inputs from CombinePayload
proto.
Posted by lc...@apache.org.
This is an automated email from the ASF dual-hosted git repository.
lcwik pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git
commit c22e1b4fcea61e374aa00cc780e71c7af50978f6
Merge: d457df7 945c3ef
Author: Lukasz Cwik <lc...@google.com>
AuthorDate: Mon Apr 9 14:37:23 2018 -0400
[BEAM-3706] Removing side inputs from CombinePayload proto.
.../pipeline/src/main/proto/beam_runner_api.proto | 9 --
.../core/construction/CombineTranslation.java | 132 +++++++--------------
.../core/construction/PTransformTranslation.java | 8 +-
.../core/construction/CombineTranslationTest.java | 46 ++++++-
.../beam/runners/direct/MultiStepCombine.java | 15 ++-
.../flink/FlinkBatchTransformTranslators.java | 30 +----
.../flink/FlinkStreamingTransformTranslators.java | 127 ++++----------------
.../functions/FlinkPartialReduceFunction.java | 1 +
.../translation/functions/FlinkReduceFunction.java | 1 +
9 files changed, 131 insertions(+), 238 deletions(-)
--
To stop receiving notification emails like this one, please contact
lcwik@apache.org.