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/04/14 00:11:37 UTC
[beam] 01/01: Merge pull request #14268: [BEAM-12011] Eliminate
WindowFn.getOutputTime method
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 6aac541d8f712a692349a642d72680144a6bb420
Merge: e094603 fcf0f50
Author: Kenn Knowles <ke...@apache.org>
AuthorDate: Tue Apr 13 17:10:59 2021 -0700
Merge pull request #14268: [BEAM-12011] Eliminate WindowFn.getOutputTime method
.../apache/beam/runners/core/WatermarkHold.java | 5 +-
.../functions/FlinkNonMergingReduceFunction.java | 5 +-
.../functions/HashingFlinkCombineRunner.java | 10 +--
.../functions/SingleWindowFlinkCombineRunner.java | 11 +--
.../functions/SortingFlinkCombineRunner.java | 15 +---
.../util/BatchGroupAlsoByWindowAndCombineFn.java | 6 +-
.../util/BatchGroupAlsoByWindowViaIteratorsFn.java | 6 +-
.../worker/StreamingGroupAlsoByWindowFnsTest.java | 14 +---
.../worker/util/GroupAlsoByWindowProperties.java | 12 +--
.../translation/batch/AggregatorCombiner.java | 6 +-
.../GroupNonMergingWindowsFunctions.java | 8 +-
.../runners/spark/translation/SparkCombineFn.java | 10 +--
.../apache/beam/sdk/testing/WindowFnTestUtils.java | 93 ----------------------
.../sdk/transforms/windowing/GlobalWindows.java | 6 --
.../transforms/windowing/PartitioningWindowFn.java | 5 --
.../sdk/transforms/windowing/SlidingWindows.java | 17 ----
.../beam/sdk/transforms/windowing/WindowFn.java | 23 ------
.../org/apache/beam/sdk/util/IdentityWindowFn.java | 6 --
.../sdk/transforms/windowing/FixedWindowsTest.java | 8 --
.../sdk/transforms/windowing/SessionsTest.java | 9 ---
.../transforms/windowing/SlidingWindowsTest.java | 17 ----
.../sdk/transforms/windowing/WindowingTest.java | 6 +-
.../sdk/io/gcp/bigquery/BigQueryIOWriteTest.java | 5 --
.../beam/sdk/nexmark/queries/WinningBids.java | 23 ------
24 files changed, 26 insertions(+), 300 deletions(-)