You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by re...@apache.org on 2021/08/02 15:35:40 UTC
[beam] branch master updated (dce846b -> 7b54b0b)
This is an automated email from the ASF dual-hosted git repository.
reuvenlax pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git.
from dce846b Merge pull request #15247: [BEAM-12686] Enable self-managed relative timers
add 8bd1e20 Ensure timer consistency in Dataflow and portable runners
add 7b54b0b Merge pull request #15123: Ensure timer consistency in runners
No new revisions were added by this update.
Summary of changes:
.../apache/beam/runners/core/TimerInternals.java | 1 +
runners/direct-java/build.gradle | 2 +
runners/google-cloud-dataflow-java/build.gradle | 2 -
.../worker/StreamingModeExecutionContext.java | 129 ++++++++---
.../dataflow/worker/WindmillTimerInternals.java | 47 ++--
...sesStatefulParDo.java => UsesLoopingTimer.java} | 4 +-
.../sdk/transforms/reflect/DoFnSignatures.java | 3 +-
.../org/apache/beam/sdk/transforms/ParDoTest.java | 77 ++++---
.../apache/beam/fn/harness/FnApiDoFnRunner.java | 175 ++++++++++-----
.../fn/harness/state/FnApiTimerBundleTracker.java | 224 +++++++++++++++++++
.../beam/fn/harness/FnApiDoFnRunnerTest.java | 238 +++++++++++----------
11 files changed, 636 insertions(+), 266 deletions(-)
copy sdks/java/core/src/main/java/org/apache/beam/sdk/testing/{UsesStatefulParDo.java => UsesLoopingTimer.java} (88%)
create mode 100644 sdks/java/harness/src/main/java/org/apache/beam/fn/harness/state/FnApiTimerBundleTracker.java