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