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 4dd45e0 [BEAM-6597] Use short id metric protocol for Java. (#14482)
add 76ef24c Revert "[BEAM-12011] Eliminate WindowFn.getOutputTime method"
add aeab089 Merge pull request #14536: [BEAM-12168] Revert "[BEAM-12011]
Eliminate WindowFn.getOutputTime method"
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 ++++
.../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, 300 insertions(+), 26 deletions(-)
