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 4a78a81 Merge pull request #14770: [BEAM-11984] Request count metrics
for GCSIO
add 90e7c1d [BEAM-8376] Google Cloud Firestore Connector - Add firestore
libraries
add 939f35e [BEAM-8376] Google Cloud Firestore Connector - Add common
classes
add 2dea3bd [BEAM-8376] Google Cloud Firestore Connector - Add RPC QoS
Classes
add a7e327c [BEAM-8376] Google Cloud Firestore Connector - Add Firestore
v1 Write Operations
add 468897a Merge pull request #14261: [BEAM-8376] Google Cloud Firestore
Connector - Add Firestore V1 Write Operations
No new revisions were added by this update.
Summary of changes:
.../org/apache/beam/gradle/BeamModulePlugin.groovy | 3 +
sdks/java/io/google-cloud-platform/build.gradle | 3 +
.../beam/sdk/io/gcp/firestore/CounterFactory.java | 29 +
.../sdk/io/gcp/firestore/DistributionFactory.java | 29 +
.../beam/sdk/io/gcp/firestore/FirestoreDoFn.java | 65 ++
.../beam/sdk/io/gcp/firestore/FirestoreIO.java | 38 +
.../sdk/io/gcp/firestore/FirestoreOptions.java | 48 ++
.../FirestoreStatefulComponentFactory.java | 121 +++
.../beam/sdk/io/gcp/firestore/FirestoreV1.java | 730 ++++++++++++++++
.../beam/sdk/io/gcp/firestore/FirestoreV1Fn.java | 59 ++
.../sdk/io/gcp/firestore/FirestoreV1WriteFn.java | 630 ++++++++++++++
.../beam/sdk/io/gcp/firestore/JodaClock.java | 28 +
.../apache/beam/sdk/io/gcp/firestore/RpcQos.java | 267 ++++++
.../beam/sdk/io/gcp/firestore/RpcQosImpl.java | 913 ++++++++++++++++++++
.../beam/sdk/io/gcp/firestore/RpcQosOptions.java | 775 +++++++++++++++++
.../beam/sdk/io/gcp/firestore/package-info.java | 27 +
.../apache/beam/sdk/io/gcp/GcpApiSurfaceTest.java | 7 +
.../sdk/io/gcp/firestore/BaseFirestoreFnTest.java | 98 +++
.../io/gcp/firestore/BaseFirestoreV1FnTest.java | 84 ++
.../gcp/firestore/BaseFirestoreV1WriteFnTest.java | 915 +++++++++++++++++++++
.../io/gcp/firestore/FirestoreProtoHelpers.java | 33 +
...storeV1FnBatchWriteWithDeadLetterQueueTest.java | 228 +++++
.../FirestoreV1FnBatchWriteWithSummaryTest.java | 250 ++++++
.../sdk/io/gcp/firestore/RpcQosOptionsTest.java | 297 +++++++
.../sdk/io/gcp/firestore/RpcQosSimulationTest.java | 251 ++++++
.../beam/sdk/io/gcp/firestore/RpcQosTest.java | 716 ++++++++++++++++
.../sdk/io/gcp/firestore/it/BaseFirestoreIT.java | 145 ++++
.../gcp/firestore/it/FirestoreTestingHelper.java | 438 ++++++++++
.../sdk/io/gcp/firestore/it/FirestoreV1IT.java | 195 +++++
29 files changed, 7422 insertions(+)
create mode 100644
sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/firestore/CounterFactory.java
create mode 100644
sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/firestore/DistributionFactory.java
create mode 100644
sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/firestore/FirestoreDoFn.java
create mode 100644
sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/firestore/FirestoreIO.java
create mode 100644
sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/firestore/FirestoreOptions.java
create mode 100644
sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/firestore/FirestoreStatefulComponentFactory.java
create mode 100644
sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/firestore/FirestoreV1.java
create mode 100644
sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/firestore/FirestoreV1Fn.java
create mode 100644
sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/firestore/FirestoreV1WriteFn.java
create mode 100644
sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/firestore/JodaClock.java
create mode 100644
sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/firestore/RpcQos.java
create mode 100644
sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/firestore/RpcQosImpl.java
create mode 100644
sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/firestore/RpcQosOptions.java
create mode 100644
sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/firestore/package-info.java
create mode 100644
sdks/java/io/google-cloud-platform/src/test/java/org/apache/beam/sdk/io/gcp/firestore/BaseFirestoreFnTest.java
create mode 100644
sdks/java/io/google-cloud-platform/src/test/java/org/apache/beam/sdk/io/gcp/firestore/BaseFirestoreV1FnTest.java
create mode 100644
sdks/java/io/google-cloud-platform/src/test/java/org/apache/beam/sdk/io/gcp/firestore/BaseFirestoreV1WriteFnTest.java
create mode 100644
sdks/java/io/google-cloud-platform/src/test/java/org/apache/beam/sdk/io/gcp/firestore/FirestoreProtoHelpers.java
create mode 100644
sdks/java/io/google-cloud-platform/src/test/java/org/apache/beam/sdk/io/gcp/firestore/FirestoreV1FnBatchWriteWithDeadLetterQueueTest.java
create mode 100644
sdks/java/io/google-cloud-platform/src/test/java/org/apache/beam/sdk/io/gcp/firestore/FirestoreV1FnBatchWriteWithSummaryTest.java
create mode 100644
sdks/java/io/google-cloud-platform/src/test/java/org/apache/beam/sdk/io/gcp/firestore/RpcQosOptionsTest.java
create mode 100644
sdks/java/io/google-cloud-platform/src/test/java/org/apache/beam/sdk/io/gcp/firestore/RpcQosSimulationTest.java
create mode 100644
sdks/java/io/google-cloud-platform/src/test/java/org/apache/beam/sdk/io/gcp/firestore/RpcQosTest.java
create mode 100644
sdks/java/io/google-cloud-platform/src/test/java/org/apache/beam/sdk/io/gcp/firestore/it/BaseFirestoreIT.java
create mode 100644
sdks/java/io/google-cloud-platform/src/test/java/org/apache/beam/sdk/io/gcp/firestore/it/FirestoreTestingHelper.java
create mode 100644
sdks/java/io/google-cloud-platform/src/test/java/org/apache/beam/sdk/io/gcp/firestore/it/FirestoreV1IT.java
