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 2ae4a28e6fc Force downgrade mpmath to avoid test breakages (#30418)
add 6c3e8ad1af1 [Dataflow Streaming] Start to refactor persistence layer
to prepare for direct path (#30265)
add 2a84a20236b [Python] Add doc comment for WriteToText.skip_if_empty
(#30409)
add b7a58bf8b2d Ensure flatten windows match (#30410)
add 8fd24b76a19 Bump google.golang.org/grpc from 1.61.0 to 1.62.0 in /sdks
(#30434)
add 0a184f449a5 Bump orjson from 3.9.14 to 3.9.15 in
/sdks/python/container/py310 (#30426)
add a1d87549f78 Make Monitoring build method public (#30431)
add 5af76b0de1a Remove unused code (#30432)
add 549faba9b98 Roll forward "Read API Source v2 (#25392)" fix data loss
(#28778)
No new revisions were added by this update.
Summary of changes:
CHANGES.md | 1 +
.../dataflow/worker/StreamingDataflowWorker.java | 278 +--
.../streaming/sideinput/SideInputStateFetcher.java | 23 +-
.../worker/windmill/state/WindmillStateReader.java | 31 +-
.../worker/StreamingDataflowWorkerTest.java | 6 +-
.../sideinput/SideInputStateFetcherTest.java | 14 +-
.../windmill/state/WindmillStateReaderTest.java | 8 +-
sdks/go.mod | 26 +-
sdks/go.sum | 56 +-
.../beam/sdk/io/gcp/bigquery/BigQueryIO.java | 177 +-
.../beam/sdk/io/gcp/bigquery/BigQueryOptions.java | 8 +-
.../io/gcp/bigquery/BigQueryStorageSourceBase.java | 57 +-
.../BigQueryStorageStreamBundleSource.java | 394 ----
...eryIOStorageReadWithStreamBundleSourceTest.java | 2156 --------------------
sdks/java/io/rrio/build.gradle | 2 -
.../apache/beam/io/requestresponse/ApiIOError.java | 25 +-
.../org/apache/beam/io/requestresponse/Call.java | 4 +-
.../apache/beam/io/requestresponse/Monitoring.java | 2 +-
.../org/apache/beam/io/requestresponse/Quota.java | 69 -
.../beam/io/requestresponse/RequestResponseIO.java | 53 -
.../ThrottleWithExternalResource.java | 418 ----
.../ThrottleWithoutExternalResource.java | 57 -
.../ThrottleWithExternalResourceIT.java | 186 --
.../ThrottleWithExternalResourceTest.java | 77 -
sdks/python/apache_beam/io/textio.py | 2 +
sdks/python/apache_beam/transforms/core.py | 8 +
sdks/python/apache_beam/transforms/core_test.py | 34 +
.../container/py310/base_image_requirements.txt | 2 +-
28 files changed, 318 insertions(+), 3856 deletions(-)
delete mode 100644
sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigquery/BigQueryStorageStreamBundleSource.java
delete mode 100644
sdks/java/io/google-cloud-platform/src/test/java/org/apache/beam/sdk/io/gcp/bigquery/BigQueryIOStorageReadWithStreamBundleSourceTest.java
delete mode 100644
sdks/java/io/rrio/src/main/java/org/apache/beam/io/requestresponse/Quota.java
delete mode 100644
sdks/java/io/rrio/src/main/java/org/apache/beam/io/requestresponse/ThrottleWithExternalResource.java
delete mode 100644
sdks/java/io/rrio/src/main/java/org/apache/beam/io/requestresponse/ThrottleWithoutExternalResource.java
delete mode 100644
sdks/java/io/rrio/src/test/java/org/apache/beam/io/requestresponse/ThrottleWithExternalResourceIT.java
delete mode 100644
sdks/java/io/rrio/src/test/java/org/apache/beam/io/requestresponse/ThrottleWithExternalResourceTest.java
