public static final class SchemaAwareStreamWriter.Builder<T>
Type Parameter |
Name |
Description |
T |
|
Methods
build()
public SchemaAwareStreamWriter<T> build()
Builds SchemaAwareStreamWriter
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.
Returns |
Type |
Description |
Builder<T> |
Builder
|
setCompressorName(String compressorName)
public SchemaAwareStreamWriter.Builder<T> setCompressorName(String compressorName)
Sets the compression to use for the calls. The compressor must be of type gzip.
Parameter |
Name |
Description |
compressorName |
String
|
Returns |
Type |
Description |
Builder<T> |
Builder
|
setCredentialsProvider(CredentialsProvider credentialsProvider)
public SchemaAwareStreamWriter.Builder<T> setCredentialsProvider(CredentialsProvider credentialsProvider)
Setter for the underlying StreamWriter's CredentialsProvider.
Returns |
Type |
Description |
Builder<T> |
Builder
|
setDefaultMissingValueInterpretation(AppendRowsRequest.MissingValueInterpretation defaultMissingValueInterpretation)
public SchemaAwareStreamWriter.Builder setDefaultMissingValueInterpretation(AppendRowsRequest.MissingValueInterpretation defaultMissingValueInterpretation)
Sets the default missing value interpretation value if the column is not presented in the
missing_value_interpretations map.
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.
Returns |
Type |
Description |
Builder<T> |
|
setFlowControlSettings(FlowControlSettings flowControlSettings)
public SchemaAwareStreamWriter.Builder<T> setFlowControlSettings(FlowControlSettings flowControlSettings)
Setter for the underlying StreamWriter's 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
|
setRetrySettings(RetrySettings retrySettings)
public SchemaAwareStreamWriter.Builder setRetrySettings(RetrySettings retrySettings)
Sets the RetrySettings to use for in-stream error retry.
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
|