This is an automated email from the ASF dual-hosted git repository.
lcwik pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git.
from 75fe1a6 Clarify CoGroupByKey creates Iterable, not list. (#16099)
add 1504892 [BEAM-12931] Allow for DoFn#getAllowedTimestampSkew() when
checking the output timestamp
No new revisions were added by this update.
Summary of changes:
CHANGES.md | 1 +
.../apache/beam/runners/core/SimpleDoFnRunner.java | 92 +++++-
.../beam/runners/core/SimpleDoFnRunnerTest.java | 355 +++++++++++++++++++--
.../org/apache/beam/sdk/transforms/ParDoTest.java | 256 ++++++++++++++-
.../apache/beam/fn/harness/FnApiDoFnRunner.java | 91 +++++-
.../beam/fn/harness/FnApiDoFnRunnerTest.java | 146 +++++++++
6 files changed, 887 insertions(+), 54 deletions(-)
