Class StreamWriterV2.Builder (3.0.1)

public static final class StreamWriterV2.Builder

A builder of StreamWriterV2s.

Inheritance

java.lang.Object > StreamWriterV2.Builder

Inherited Members

Object.clone()

Object.equals(Object)

Object.finalize()

Object.getClass()

Object.hashCode()

Object.notify()

Object.notifyAll()

Object.toString()

Object.wait()

Object.wait(long)

Object.wait(long,int)

Methods

build()

public StreamWriterV2 build()

Builds the StreamWriterV2.

Returns
Type	Description
`StreamWriterV2`

Exceptions
Type	Description
`IOException`

setChannelProvider(TransportChannelProvider channelProvider)

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 com.google.api.gax.grpc.InstantiatingGrpcChannelProvider.Builder#setPoolSize(int).

Parameter
Name	Description
`channelProvider`	`TransportChannelProvider`

Returns
Type	Description
`StreamWriterV2.Builder`

setCredentialsProvider(CredentialsProvider credentialsProvider)

public StreamWriterV2.Builder setCredentialsProvider(CredentialsProvider credentialsProvider)

CredentialsProvider to use to create Credentials to authenticate calls.

Parameter
Name	Description
`credentialsProvider`	`CredentialsProvider`

Returns
Type	Description
`StreamWriterV2.Builder`

setEndpoint(String endpoint)

public StreamWriterV2.Builder setEndpoint(String endpoint)

Gives the ability to override the gRPC endpoint.

Parameter
Name	Description
`endpoint`	`String`

Returns
Type	Description
`StreamWriterV2.Builder`

setMaxInflightBytes(long value)

public StreamWriterV2.Builder setMaxInflightBytes(long value)

Parameter
Name	Description
`value`	`long`

Returns
Type	Description
`StreamWriterV2.Builder`

setMaxInflightRequests(long value)

public StreamWriterV2.Builder setMaxInflightRequests(long value)

Parameter
Name	Description
`value`	`long`

Returns
Type	Description
`StreamWriterV2.Builder`

setTraceId(String traceId)

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.

Parameter
Name	Description
`traceId`	`String`

Returns
Type	Description
`StreamWriterV2.Builder`

setWriterSchema(ProtoSchema writerSchema)

public StreamWriterV2.Builder setWriterSchema(ProtoSchema writerSchema)

Sets the proto schema of the rows.

Parameter
Name	Description
`writerSchema`	`ProtoSchema`

Returns
Type	Description
`StreamWriterV2.Builder`