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 9ea7380de85 Refactor update compatibility checks and pipeline options
access (#37566)
add 72ce2074caf GCS client library migration in Java SDK - part 2 (#37502)
add cbf36740a53 Add Support for EnvoyRateLimiter Implementation (#37573)
add 695498f03a4 Update testcontainers version (#37591)
add eba1ec36adc Bigtable: skip reading large rows (#37586)
add 0adeae8b771 Optimize data size estimation for proto coder.
add 9a1dedfea25 Use existing _get_nested_size utility.
add 6e81f250977 Merge pull request #37584 Optimize data size estimation
for proto coder.
add c7d13c4d56d add aws and azure dependencies (#37602)
No new revisions were added by this update.
Summary of changes:
.../org/apache/beam/gradle/BeamModulePlugin.groovy | 4 +-
examples/java/build.gradle | 1 +
.../apache/beam/examples/RateLimiterSimple.java | 131 +++++++++
.../resources/beam/checkstyle/suppressions.xml | 1 +
.../google-cloud-platform-core/build.gradle | 3 +
.../beam/sdk/extensions/gcp/util/GcsUtil.java | 111 ++++++-
.../beam/sdk/extensions/gcp/util/GcsUtilV1.java | 20 +-
.../beam/sdk/extensions/gcp/util/GcsUtilV2.java | 325 +++++++++++++++++++++
.../sdk/extensions/gcp/util/gcsfs/GcsPath.java | 15 +
.../sdk/extensions/gcp/GcpCoreApiSurfaceTest.java | 15 +-
.../gcp/util/GcsUtilParameterizedIT.java | 300 +++++++++++++++++++
.../sdk/extensions/gcp/util/gcsfs/GcsPathTest.java | 20 ++
sdks/java/io/components/build.gradle | 5 +
.../components/ratelimiter/EnvoyRateLimiter.java} | 32 +-
.../ratelimiter/EnvoyRateLimiterContext.java | 65 +++++
.../ratelimiter/EnvoyRateLimiterFactory.java | 238 +++++++++++++++
.../ratelimiter/RateLimiterClientCache.java | 103 +++++++
.../components/ratelimiter/RateLimiterOptions.java | 68 +++++
.../ratelimiter/EnvoyRateLimiterTest.java | 168 +++++++++++
.../ratelimiter/RateLimiterClientCacheTest.java | 115 ++++++++
.../ratelimiter/RateLimiterOptionsTest.java | 81 +++++
.../io/gcp/bigtable/BigtableServiceFactory.java | 7 +-
.../sdk/io/gcp/bigtable/BigtableServiceImpl.java | 31 +-
.../beam/sdk/io/gcp/bigtable/BigtableReadIT.java | 41 +++
.../io/gcp/bigtable/BigtableServiceImplTest.java | 3 +-
sdks/java/io/iceberg/build.gradle | 4 +
sdks/python/apache_beam/coders/coder_impl.py | 6 +
27 files changed, 1866 insertions(+), 47 deletions(-)
create mode 100644
examples/java/src/main/java/org/apache/beam/examples/RateLimiterSimple.java
create mode 100644
sdks/java/extensions/google-cloud-platform-core/src/main/java/org/apache/beam/sdk/extensions/gcp/util/GcsUtilV2.java
create mode 100644
sdks/java/extensions/google-cloud-platform-core/src/test/java/org/apache/beam/sdk/extensions/gcp/util/GcsUtilParameterizedIT.java
copy
sdks/java/{core/src/test/java/org/apache/beam/sdk/util/FastNanoClockAndSleeper.java
=>
io/components/src/main/java/org/apache/beam/sdk/io/components/ratelimiter/EnvoyRateLimiter.java}
(55%)
create mode 100644
sdks/java/io/components/src/main/java/org/apache/beam/sdk/io/components/ratelimiter/EnvoyRateLimiterContext.java
create mode 100644
sdks/java/io/components/src/main/java/org/apache/beam/sdk/io/components/ratelimiter/EnvoyRateLimiterFactory.java
create mode 100644
sdks/java/io/components/src/main/java/org/apache/beam/sdk/io/components/ratelimiter/RateLimiterClientCache.java
create mode 100644
sdks/java/io/components/src/main/java/org/apache/beam/sdk/io/components/ratelimiter/RateLimiterOptions.java
create mode 100644
sdks/java/io/components/src/test/java/org/apache/beam/sdk/io/components/ratelimiter/EnvoyRateLimiterTest.java
create mode 100644
sdks/java/io/components/src/test/java/org/apache/beam/sdk/io/components/ratelimiter/RateLimiterClientCacheTest.java
create mode 100644
sdks/java/io/components/src/test/java/org/apache/beam/sdk/io/components/ratelimiter/RateLimiterOptionsTest.java
