Send feedback
Class SchemaAwareStreamWriter.Builder<T> (3.10.3)
Stay organized with collections
Save and categorize content based on your preferences.
Version 3.10.3 keyboard_arrow_down
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
compressorNameString
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
enableConnectionPoolboolean
Returns
Type Description
Builder <T >Builder
setEnableLatencyProfiler(boolean enableLatencyProfiler)
public SchemaAwareStreamWriter . Builder setEnableLatencyProfiler ( boolean enableLatencyProfiler )
Enable a latency profiler that would periodically generate a detailed latency report for the
top latency requests. This is currently an experimental API.
Parameter
Name Description
enableLatencyProfilerboolean
setEnableOpenTelemetry(boolean enableOpenTelemetry)
public SchemaAwareStreamWriter . Builder setEnableOpenTelemetry ( boolean enableOpenTelemetry )
Enable generation of metrics for OpenTelemetry.
Parameter
Name Description
enableOpenTelemetryboolean
setEndpoint(String endpoint)
public SchemaAwareStreamWriter . Builder<T> setEndpoint ( String endpoint )
Setter for the underlying StreamWriter's Endpoint.
Parameter
Name Description
endpointString
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. 1
Parameter
Name Description
ignoreUnknownFieldsboolean
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
locationString
Returns
Type Description
Builder <T >Builder
setMissingValueInterpretationMap(Map<String,AppendRowsRequest.MissingValueInterpretation> missingValueInterpretationMap)
public SchemaAwareStreamWriter . Builder setMissingValueInterpretationMap ( Map<String , AppendRowsRequest . MissingValueInterpretation > missingValueInterpretationMap )
Sets the missing value interpretation map for the SchemaAwareStreamWriter. The input
missingValueInterpretationMap is used for all append requests unless otherwise changed.
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
traceIdString
Returns
Type Description
Builder <T >Builder
Send feedback
Except as otherwise noted, the content of this page is licensed under the Creative Commons Attribution 4.0 License , and code samples are licensed under the Apache 2.0 License . For details, see the Google Developers Site Policies . Java is a registered trademark of Oracle and/or its affiliates.
Last updated 2024-12-18 UTC.
Need to tell us more?
[[["Easy to understand","easyToUnderstand","thumb-up"],["Solved my problem","solvedMyProblem","thumb-up"],["Other","otherUp","thumb-up"]],[["Hard to understand","hardToUnderstand","thumb-down"],["Incorrect information or sample code","incorrectInformationOrSampleCode","thumb-down"],["Missing the information/samples I need","missingTheInformationSamplesINeed","thumb-down"],["Other","otherDown","thumb-down"]],["Last updated 2024-12-18 UTC."],[],[]]
