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
lc...@apache.org.
