Package com.google.cloud.bigquery.storage.v1beta2

Class StreamWriterV2.Builder

java.lang.Object

com.google.cloud.bigquery.storage.v1beta2.StreamWriterV2.Builder

Enclosing class:

StreamWriterV2

public static final class StreamWriterV2.Builder
extends Object

A builder of StreamWriterV2s.

Method Summary

Modifier and Type	Method	Description
StreamWriterV2	build()	Builds the StreamWriterV2.
StreamWriterV2.Builder	setChannelProvider(TransportChannelProvider channelProvider)	ChannelProvider to use to create Channels, which must point at Cloud BigQuery Storage API endpoint.
StreamWriterV2.Builder	setCredentialsProvider(CredentialsProvider credentialsProvider)	CredentialsProvider to use to create Credentials to authenticate calls.
StreamWriterV2.Builder	setEndpoint(String endpoint)	Gives the ability to override the gRPC endpoint.
StreamWriterV2.Builder	setMaxInflightBytes(long value)
StreamWriterV2.Builder	setMaxInflightRequests(long value)
StreamWriterV2.Builder	setTraceId(String traceId)	Sets traceId for debuging purpose.
StreamWriterV2.Builder	setWriterSchema(ProtoSchema writerSchema)	Sets the proto schema of the rows.

Methods inherited from class java.lang.Object

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

Method Details

setWriterSchema

public StreamWriterV2.Builder setWriterSchema(ProtoSchema writerSchema)

Sets the proto schema of the rows.

setMaxInflightRequests

public StreamWriterV2.Builder setMaxInflightRequests(long value)

setMaxInflightBytes

public StreamWriterV2.Builder setMaxInflightBytes(long value)

setEndpoint

public StreamWriterV2.Builder setEndpoint(String endpoint)

Gives the ability to override the gRPC endpoint.

setChannelProvider

public StreamWriterV2.Builder setChannelProvider(TransportChannelProvider channelProvider)

ChannelProvider to use to create Channels, which must point at Cloud BigQuery Storage API endpoint.

For performance, this client benefits from having multiple underlying connections. See InstantiatingGrpcChannelProvider.Builder.setPoolSize(int).

setCredentialsProvider

public StreamWriterV2.Builder setCredentialsProvider(CredentialsProvider credentialsProvider)

CredentialsProvider to use to create Credentials to authenticate calls.

setTraceId

public StreamWriterV2.Builder setTraceId(String traceId)

Sets traceId for debuging purpose. TraceId must follow the format of CustomerDomain:DebugString, e.g. DATAFLOW:job_id_x.

build

public StreamWriterV2 build()
                     throws IOException

Builds the StreamWriterV2.

Throws:

IOException