public static final class FirestoreV1.BatchWriteWithDeadLetterQueue extends PTransform<InT,OutT>
>which will write to Firestore.
FirestoreV1.WriteFailures output by this
PTransformare those writes which were not able to be applied to Cloud Firestore.
Use this BatchWrite when you do not want a failed write to error an entire bundle.
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.WriteFailure> 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.BatchWriteWithDeadLetterQueue.Builder toBuilder()
Builderfrom the current instance.
Builderinitialized to the current state of this instance