This is an automated email from the ASF dual-hosted git repository.
github-bot pushed a change to branch nightly-refs/heads/master
in repository https://gitbox.apache.org/repos/asf/beam.git
from f1c72c5e0c4 Support metrics at Source.split for Direct Runner (#32022)
add 56aa17b59ec Change the gradle task definition in quickstart. (#32043)
add 21009e68eab StateWatcher watches and reports changed Pipeline State
(#32040)
add 6aac47c8354 [CsvIO] Create CsvIOParse Class (#32028)
add b795a61f094 Adds null checks when accessing OperationalLimits in
config since they might not have been set yet. (#32053)
add 202fa56be77 Enable ExternalWorkerService during Prism Runner lifecycle
(#32057)
No new revisions were added by this update.
Summary of changes:
.../StreamingEngineComputationConfigFetcher.java | 6 +-
runners/prism/java/build.gradle | 4 +
.../{package-info.java => StateListener.java} | 11 +-
.../apache/beam/runners/prism/StateWatcher.java | 146 ++++++++++
.../apache/beam/runners/prism/WorkerService.java | 116 ++++++++
.../beam/runners/prism/StateWatcherTest.java | 136 ++++++++++
.../beam/runners/prism/WorkerServiceTest.java | 85 ++++++
.../java/org/apache/beam/sdk/io/csv/CsvIO.java | 162 +++++++++++
.../org/apache/beam/sdk/io/csv/CsvIOParse.java | 84 ++++++
.../beam/sdk/io/csv/CsvIOStringToCsvRecord.java | 2 +-
.../org/apache/beam/sdk/io/csv/CsvIOParseTest.java | 197 ++++++++++++++
.../sdk/io/csv/CsvIOStringToCsvRecordTest.java | 12 +
.../java/org/apache/beam/sdk/io/csv/CsvIOTest.java | 300 +++++++++++++++++++++
.../site/content/en/get-started/quickstart-java.md | 2 +-
14 files changed, 1257 insertions(+), 6 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/main/java/org/apache/beam/runners/prism/WorkerService.java
create mode 100644
runners/prism/java/src/test/java/org/apache/beam/runners/prism/StateWatcherTest.java
create mode 100644
runners/prism/java/src/test/java/org/apache/beam/runners/prism/WorkerServiceTest.java
create mode 100644
sdks/java/io/csv/src/main/java/org/apache/beam/sdk/io/csv/CsvIOParse.java
create mode 100644
sdks/java/io/csv/src/test/java/org/apache/beam/sdk/io/csv/CsvIOParseTest.java
create mode 100644
sdks/java/io/csv/src/test/java/org/apache/beam/sdk/io/csv/CsvIOTest.java
