You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by ke...@apache.org on 2021/02/27 04:30:23 UTC

[beam] 01/01: Merge pull request #14059: [BEAM-11866] Remove InvalidWindows from Java SDK, instead track "already merged" bit

This is an automated email from the ASF dual-hosted git repository.

kenn pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git

commit 4764c0a6bc641525699150b6489f115f8cecf7e7
Merge: 687035c 3a438fa
Author: Kenn Knowles <ke...@apache.org>
AuthorDate: Fri Feb 26 20:29:06 2021 -0800

    Merge pull request #14059: [BEAM-11866] Remove InvalidWindows from Java SDK, instead track "already merged" bit

 .../construction/WindowingStrategyTranslation.java |  4 +-
 .../apache/beam/runners/core/ReduceFnRunner.java   |  4 +-
 .../beam/runners/direct/MultiStepCombine.java      |  2 +-
 .../flink/FlinkBatchTransformTranslators.java      |  4 +-
 .../flink/FlinkStreamingTransformTranslators.java  |  2 +-
 .../functions/FlinkPartialReduceFunction.java      |  2 +-
 .../translation/functions/FlinkReduceFunction.java |  2 +-
 .../functions/HashingFlinkCombineRunner.java       |  2 +-
 .../functions/SortingFlinkCombineRunner.java       |  2 +-
 .../dataflow/DataflowPipelineTranslator.java       |  5 +-
 .../beam/runners/dataflow/DataflowRunner.java      |  2 +-
 .../transforms/DataflowGroupByKeyTest.java         | 24 ------
 .../dataflow/transforms/DataflowViewTest.java      | 71 -----------------
 .../util/BatchGroupAlsoByWindowViaIteratorsFn.java |  2 +-
 .../org/apache/beam/runners/spark/SparkRunner.java |  2 +-
 .../translation/batch/AggregatorCombiner.java      |  2 +-
 .../GroupNonMergingWindowsFunctions.java           |  2 +-
 .../runners/spark/translation/SparkCombineFn.java  |  2 +-
 .../org/apache/beam/sdk/transforms/Distinct.java   |  2 +-
 .../org/apache/beam/sdk/transforms/GroupByKey.java | 22 +-----
 .../sdk/transforms/windowing/InvalidWindows.java   | 90 ----------------------
 .../beam/sdk/transforms/windowing/Window.java      | 18 +----
 .../org/apache/beam/sdk/util/IdentityWindowFn.java | 11 +--
 .../apache/beam/sdk/values/PCollectionViews.java   |  4 -
 .../apache/beam/sdk/values/WindowingStrategy.java  | 65 +++++++++++++---
 .../apache/beam/sdk/transforms/GroupByKeyTest.java | 70 +++++++++--------
 .../org/apache/beam/sdk/transforms/ViewTest.java   | 42 ----------
 27 files changed, 119 insertions(+), 341 deletions(-)