You are viewing a plain text version of this content. The canonical link for it is here.

Posted to commits@beam.apache.org by da...@apache.org on 2024/08/01 18:10:48 UTC

(beam) branch master updated (56aa17b59ec -> 21009e68eab)

This is an automated email from the ASF dual-hosted git repository.

damondouglas pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git


    from 56aa17b59ec Change the gradle task definition in quickstart. (#32043)
     add 21009e68eab StateWatcher watches and reports changed Pipeline State (#32040)

No new revisions were added by this update.

Summary of changes:
 runners/prism/java/build.gradle                    |   2 +
 .../{package-info.java => StateListener.java}      |  11 +-
 .../apache/beam/runners/prism/StateWatcher.java    | 146 +++++++++++++++++++++
 .../beam/runners/prism/StateWatcherTest.java       | 136 +++++++++++++++++++
 4 files changed, 293 insertions(+), 2 deletions(-)
 copy runners/prism/java/src/main/java/org/apache/beam/runners/prism/{package-info.java => StateListener.java} (72%)
 create mode 100644 runners/prism/java/src/main/java/org/apache/beam/runners/prism/StateWatcher.java
 create mode 100644 runners/prism/java/src/test/java/org/apache/beam/runners/prism/StateWatcherTest.java