You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by ie...@apache.org on 2019/05/29 09:37:56 UTC
[beam] 01/01: Merge pull request #8711: [BEAM-7448] Remove
redundant windowing information and unused accumulators on Spark runner
This is an automated email from the ASF dual-hosted git repository.
iemejia pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git
commit cd8c6ec57c92baf5088ab52fa5b9f77d211ba40b
Merge: 23115ce fa96678
Author: Ismaël Mejía <ie...@gmail.com>
AuthorDate: Wed May 29 11:37:34 2019 +0200
Merge pull request #8711: [BEAM-7448] Remove redundant windowing information and unused accumulators on Spark runner
.../spark/stateful/SparkGroupAlsoByWindowViaWindowSet.java | 9 +++------
.../runners/spark/translation/GroupCombineFunctions.java | 6 ++----
.../translation/SparkBatchPortablePipelineTranslator.java | 6 ++----
.../SparkGroupAlsoByWindowViaOutputBufferFn.java | 13 +++++--------
.../runners/spark/translation/TransformTranslator.java | 14 +++++---------
.../streaming/StreamingTransformTranslator.java | 2 +-
6 files changed, 18 insertions(+), 32 deletions(-)