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 <k...@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(-)
