This is an automated email from the ASF dual-hosted git repository.
chamikara pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git.
from c986168 [BEAM-11289] [Java] Integrate Google Cloud Recommendations AI
functionality
add fcd3fcc [BEAM-12260] Java - Backport Firestore connector's ramp-up
throttling to Datastore connector (#14713)
No new revisions were added by this update.
Summary of changes:
CHANGES.md | 2 +
.../beam/sdk/io/gcp/datastore/DatastoreV1.java | 177 +++++++++++++++++----
.../sdk/io/gcp/datastore/RampupThrottlingFn.java | 130 +++++++++++++++
.../beam/sdk/io/gcp/datastore/DatastoreV1Test.java | 60 +++++--
.../io/gcp/datastore/RampupThrottlingFnTest.java | 88 ++++++++++
5 files changed, 413 insertions(+), 44 deletions(-)
create mode 100644
sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/datastore/RampupThrottlingFn.java
create mode 100644
sdks/java/io/google-cloud-platform/src/test/java/org/apache/beam/sdk/io/gcp/datastore/RampupThrottlingFnTest.java
