Class SchemaAwareStreamWriter.Builder<T> (2.37.0)

public static final class SchemaAwareStreamWriter.Builder<T>

Inheritance

java.lang.Object > SchemaAwareStreamWriter.Builder<T>

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)

Type Parameter
Name	Description
`T`

Methods

build()

public SchemaAwareStreamWriter<T> build()

Builds SchemaAwareStreamWriter

Returns
Type	Description
`SchemaAwareStreamWriter<T>`	SchemaAwareStreamWriter

Exceptions
Type	Description
`DescriptorValidationException`
`IllegalArgumentException`
`IOException`
`InterruptedException`

getStreamName()

public String getStreamName()

Stream name on the builder.

Returns
Type	Description
`String`	Builder

setChannelProvider(TransportChannelProvider channelProvider)

public SchemaAwareStreamWriter.Builder<T> setChannelProvider(TransportChannelProvider channelProvider)

Setter for the underlying StreamWriter's TransportChannelProvider.

Parameter
Name	Description
`channelProvider`	`TransportChannelProvider`

Returns
Type	Description
`Builder<T>`	Builder

setCredentialsProvider(CredentialsProvider credentialsProvider)

public SchemaAwareStreamWriter.Builder<T> setCredentialsProvider(CredentialsProvider credentialsProvider)

Setter for the underlying StreamWriter's CredentialsProvider.

Parameter
Name	Description
`credentialsProvider`	`CredentialsProvider`

Returns
Type	Description
`Builder<T>`	Builder

setEnableConnectionPool(boolean enableConnectionPool)

public SchemaAwareStreamWriter.Builder<T> setEnableConnectionPool(boolean enableConnectionPool)

Enable multiplexing for this writer. In multiplexing mode tables will share the same connection if possible until the connection is overwhelmed. This feature is still under development, please contact write api team before using.

Parameter
Name	Description
`enableConnectionPool`	`boolean`

Returns
Type	Description
`Builder<T>`	Builder

setEndpoint(String endpoint)

public SchemaAwareStreamWriter.Builder<T> setEndpoint(String endpoint)

Setter for the underlying StreamWriter's Endpoint.

Parameter
Name	Description
`endpoint`	`String`

Returns
Type	Description
`Builder<T>`	Builder

setExecutorProvider(ExecutorProvider executorProvider)

public SchemaAwareStreamWriter.Builder<T> setExecutorProvider(ExecutorProvider executorProvider)

Setter for the underlying StreamWriter's ExecutorProvider.

Parameter
Name	Description
`executorProvider`	`ExecutorProvider`

Returns
Type	Description
`Builder<T>`

setFlowControlSettings(FlowControlSettings flowControlSettings)

public SchemaAwareStreamWriter.Builder<T> setFlowControlSettings(FlowControlSettings flowControlSettings)

Setter for the underlying StreamWriter's FlowControlSettings.

Parameter
Name	Description
`flowControlSettings`	`FlowControlSettings`

Returns
Type	Description
`Builder<T>`	Builder

setIgnoreUnknownFields(boolean ignoreUnknownFields)

public SchemaAwareStreamWriter.Builder<T> setIgnoreUnknownFields(boolean ignoreUnknownFields)

Setter for a ignoreUnknownFields, if true, unknown fields to BigQuery will be ignored instead of error out.

Parameter
Name	Description
`ignoreUnknownFields`	`boolean`

Returns
Type	Description
`Builder<T>`	Builder

setLocation(String location)

public SchemaAwareStreamWriter.Builder<T> setLocation(String location)

Location of the table this stream writer is targeting. Connection pools are shared by location.

Parameter
Name	Description
`location`	`String`

Returns
Type	Description
`Builder<T>`	Builder

setTraceId(String traceId)

public SchemaAwareStreamWriter.Builder<T> setTraceId(String traceId)

Setter for a traceId to help identify traffic origin.

Parameter
Name	Description
`traceId`	`String`

Returns
Type	Description
`Builder<T>`	Builder

setTraceIdBase(String traceIdBase)

public SchemaAwareStreamWriter.Builder<T> setTraceIdBase(String traceIdBase)

Setter for a traceIdBase to help identify traffic origin.

Parameter
Name	Description
`traceIdBase`	`String`

Returns
Type	Description
`Builder<T>`	Builder