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
