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 21:45:05 UTC
[beam] branch master updated (4732bed -> 4b7b746)
This is an automated email from the ASF dual-hosted git repository.
kenn pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git.
from 4732bed Merge pull request #14532: [BEAM-12136] Add deterministic coder for enum.Enum
add 240185f Remove uses of WindowFn.getOutputTime
add 4b7b746 Merge pull request #14540: Remove uses of WindowFn.getOutputTime
No new revisions were added by this update.
Summary of changes:
.../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 ----
.../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 ------
23 files changed, 26 insertions(+), 277 deletions(-)