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 bb0a2037970 Merge pull request #29811: Bump
org.checkerframework:checkerframework-gradle-plugin from 0.6.34 to 0.6.37
add 8fb06da4ce8 [RRIO] Build RequestResponseIO and related dependency
changes (#29710)
No new revisions were added by this update.
Summary of changes:
.../apache/beam/io/requestresponse/ApiIOError.java | 7 +-
.../org/apache/beam/io/requestresponse/Cache.java | 190 +++++--
.../org/apache/beam/io/requestresponse/Call.java | 377 ++++++++++----
.../beam/io/requestresponse/CallShouldBackoff.java | 2 +-
...llShouldBackoffBasedOnRejectionProbability.java | 2 +-
...ava => DefaultSerializableBackoffSupplier.java} | 24 +-
.../apache/beam/io/requestresponse/Monitoring.java | 362 ++++++++++++++
.../org/apache/beam/io/requestresponse/Quota.java | 7 +-
.../beam/io/requestresponse/RedisClient.java | 4 +-
.../apache/beam/io/requestresponse/Repeater.java | 85 +++-
.../beam/io/requestresponse/RequestResponseIO.java | 552 +++++++++++++++++++--
.../org/apache/beam/io/requestresponse/Result.java | 65 +--
.../{Caller.java => SerializableSupplier.java} | 13 +-
.../ThrottleWithExternalResource.java | 12 +-
.../UserCodeExecutionException.java | 8 +
.../io/requestresponse/UserCodeQuotaException.java | 6 +
.../UserCodeRemoteSystemException.java | 9 +
.../requestresponse/UserCodeTimeoutException.java | 9 +
.../requestresponse/WindowedCallShouldBackoff.java | 76 +++
.../apache/beam/io/requestresponse/CacheIT.java | 16 +-
...ouldBackoffBasedOnRejectionProbabilityTest.java | 2 +-
.../apache/beam/io/requestresponse/CallTest.java | 1 -
.../EchoGRPCCallerWithSetupTeardownIT.java | 2 +-
.../beam/io/requestresponse/EchoRequestCoder.java | 1 +
...choRequestCoder.java => EchoResponseCoder.java} | 13 +-
.../beam/io/requestresponse/RedisClientIT.java | 2 +-
.../beam/io/requestresponse/RepeaterTest.java | 2 +-
.../io/requestresponse/RequestResponseIOIT.java | 95 ++++
.../io/requestresponse/RequestResponseIOTest.java | 508 +++++++++++++++++++
.../ThrottleWithExternalResourceIT.java | 6 +-
.../WindowedCallShouldBackoffTest.java | 56 +++
31 files changed, 2225 insertions(+), 289 deletions(-)
copy
sdks/java/io/rrio/src/main/java/org/apache/beam/io/requestresponse/{CallShouldBackoff.java
=> DefaultSerializableBackoffSupplier.java} (61%)
create mode 100644
sdks/java/io/rrio/src/main/java/org/apache/beam/io/requestresponse/Monitoring.java
copy
.test-infra/pipelines/src/main/java/org/apache/beam/testinfra/pipelines/conversions/RowConversionResult.java
=>
sdks/java/io/rrio/src/main/java/org/apache/beam/io/requestresponse/Result.java
(54%)
copy
sdks/java/io/rrio/src/main/java/org/apache/beam/io/requestresponse/{Caller.java
=> SerializableSupplier.java} (74%)
create mode 100644
sdks/java/io/rrio/src/main/java/org/apache/beam/io/requestresponse/WindowedCallShouldBackoff.java
copy
sdks/java/io/rrio/src/test/java/org/apache/beam/io/requestresponse/{EchoRequestCoder.java
=> EchoResponseCoder.java} (74%)
create mode 100644
sdks/java/io/rrio/src/test/java/org/apache/beam/io/requestresponse/RequestResponseIOIT.java
create mode 100644
sdks/java/io/rrio/src/test/java/org/apache/beam/io/requestresponse/RequestResponseIOTest.java
create mode 100644
sdks/java/io/rrio/src/test/java/org/apache/beam/io/requestresponse/WindowedCallShouldBackoffTest.java
