public static final class FirestoreV1.BatchWriteWithSummary extends PTransform<InT,OutT>
>which will write to Firestore.
If an error is encountered while trying to write to Cloud Firestore a
FirestoreV1.FailedWritesException will be thrown. If you would like a failed write to not result in a
FirestoreV1.FailedWritesException, you can instead use
will instead output any failed write.
FirestoreV1.BatchWriteWithDeadLetterQueue can be used by
FirestoreV1.BatchWriteWithSummary.Builder.withDeadLetterQueue() when constructing the write handler.
This class is part of the Firestore Connector DSL, it has a type safe builder accessible via
All request quality-of-service for an instance of this PTransform is scoped to the worker
and configured via
Writes performed against Firestore will be ordered and grouped to maximize throughput while maintaining a high request success rate. Batch sizes will be determined by the QOS layer.
BatchWriteResponse, google.firestore.v1.Firestore.BatchWrite, google.firestore.v1.BatchWriteRequest, google.firestore.v1.BatchWriteResponse, Serialized Form
|Modifier and Type||Class and Description|
A type safe builder for
|Modifier and Type||Method and Description|
Override this method to specify how this
Create a new
compose, compose, getAdditionalInputs, getDefaultOutputCoder, getDefaultOutputCoder, getDefaultOutputCoder, getKindString, getName, getResourceHints, setResourceHints, toString, validate, validate
public PCollection<FirestoreV1.WriteSuccessSummary> expand(PCollection<com.google.firestore.v1.Write> input)
PTransformshould be expanded on the given
NOTE: This method should not be called directly. Instead apply the
be applied to the
InputT using the
Composite transforms, which are defined in terms of other transforms, should return the output of one of the composed transforms. Non-composite transforms, which do not apply any transforms internally, should return a new unbound output and register evaluators (via backend-specific registration methods).
public FirestoreV1.BatchWriteWithSummary.Builder toBuilder()
Builderfrom the current instance.
Builderinitialized to the current state of this instance