Class StreamWriter.Builder (2.43.0)
Note: Some or all of the information on this page might not apply
to Trusted Cloud. For a list of services that are available in
Trusted Cloud, see Services available for
Trusted Cloud .
Version 2.43.0keyboard_arrow_down
public static final class StreamWriter . Builder
Methods
build()
public StreamWriter build ()
Builds the StreamWriterV2.
setChannelProvider(TransportChannelProvider channelProvider)
public StreamWriter . 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) .
setCompressorName(String compressorName)
public StreamWriter . Builder setCompressorName ( String compressorName )
Parameter
Name Description
compressorNameString
setCredentialsProvider(CredentialsProvider credentialsProvider)
public StreamWriter . Builder setCredentialsProvider ( CredentialsProvider credentialsProvider )
CredentialsProvider to use to create Credentials to authenticate calls.
setDefaultMissingValueInterpretation(AppendRowsRequest.MissingValueInterpretation defaultMissingValueInterpretation)
public StreamWriter . 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 StreamWriter . Builder setEnableConnectionPool ( boolean enableConnectionPool )
Enable multiplexing for this writer. In multiplexing mode tables will share the same
connection if possible until the connection is overwhelmed.
Parameter
Name Description
enableConnectionPoolboolean
setEndpoint(String endpoint)
public StreamWriter . Builder setEndpoint ( String endpoint )
Gives the ability to override the gRPC endpoint.
Parameter
Name Description
endpointString
setExecutorProvider(ExecutorProvider executorProvider)
public StreamWriter . Builder setExecutorProvider ( ExecutorProvider executorProvider )
ExecutorProvider to use to create Executor to run background jobs.
setLimitExceededBehavior(FlowController.LimitExceededBehavior limitExceededBehavior)
public StreamWriter . Builder setLimitExceededBehavior ( FlowController . LimitExceededBehavior limitExceededBehavior )
Sets the limit exceeded behavior.
Exceptions
Type Description
io.grpc.StatusRuntimeException
setLocation(String location)
public StreamWriter . Builder setLocation ( String location )
Location of the table this stream writer is targeting.
Parameter
Name Description
locationString
setMaxInflightBytes(long value)
public StreamWriter . Builder setMaxInflightBytes ( long value )
Parameter
Name Description
valuelong
setMaxInflightRequests(long value)
public StreamWriter . Builder setMaxInflightRequests ( long value )
Parameter
Name Description
valuelong
setMaxRetryDuration(Duration maxRetryDuration)
public StreamWriter . Builder setMaxRetryDuration ( Duration maxRetryDuration )
Parameter
Name Description
maxRetryDurationDuration
setTraceId(String traceId)
public StreamWriter . 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
traceIdString
setWriterSchema(ProtoSchema writerSchema)
public StreamWriter . Builder setWriterSchema ( ProtoSchema writerSchema )
Sets the proto schema of the rows.
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 2025-08-18 UTC.
[[["Easy to understand","easyToUnderstand","thumb-up"],["Solved my problem","solvedMyProblem","thumb-up"],["Other","otherUp","thumb-up"]],[["Missing the information I need","missingTheInformationINeed","thumb-down"],["Too complicated / too many steps","tooComplicatedTooManySteps","thumb-down"],["Out of date","outOfDate","thumb-down"],["Samples / code issue","samplesCodeIssue","thumb-down"],["Other","otherDown","thumb-down"]],["Last updated 2025-08-18 UTC."],[],[],null,[]]
