org.apache.beam.sdk.io.gcp.firestore

Class FirestoreV1.BatchWriteWithDeadLetterQueue.Builder

java.lang.Object

org.apache.beam.sdk.io.gcp.firestore.FirestoreV1.BatchWriteWithDeadLetterQueue.Builder

Enclosing class:

FirestoreV1.BatchWriteWithDeadLetterQueue

public static final class FirestoreV1.BatchWriteWithDeadLetterQueue.Builder
extends java.lang.Object

A type safe builder for FirestoreV1.BatchWriteWithDeadLetterQueue allowing configuration and instantiation.

This class is part of the Firestore Connector DSL, it has a type safe builder accessible via FirestoreIO.v1().write().batchWrite().

See Also:

FirestoreIO.v1(), FirestoreV1.write(), FirestoreV1.Write.batchWrite(), FirestoreV1.BatchWriteWithSummary, BatchWriteRequest, BatchWriteResponse, google.firestore.v1.Firestore.BatchWrite, google.firestore.v1.BatchWriteRequest, google.firestore.v1.BatchWriteResponse

Method Summary

Modifier and Type	Method and Description
FirestoreV1.BatchWriteWithDeadLetterQueue	build() Create a new instance of Transform from the current builder state.
BldrT	withRpcQosOptions(RpcQosOptions rpcQosOptions) Specify the RpcQosOptions that will be used when bootstrapping the QOS of each running instance of the Transform created by this builder.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Method Detail

build

public FirestoreV1.BatchWriteWithDeadLetterQueue build()

Create a new instance of Transform from the current builder state.

Returns:

a new instance of Transform from the current builder state.

withRpcQosOptions

public final BldrT withRpcQosOptions(RpcQosOptions rpcQosOptions)

Specify the RpcQosOptions that will be used when bootstrapping the QOS of each running instance of the Transform created by this builder.

NOTE This method behaves as set, mutating the value in this builder instance.

Parameters:

rpcQosOptions - The QOS Options to use when bootstrapping and running the built Transform.

Returns:

this builder

See Also:

RpcQosOptions, RpcQosOptions.defaultOptions(), RpcQosOptions.newBuilder()