static StreamWriter.Builder |
StreamWriter.newBuilder(String streamName) |
|
static StreamWriter.Builder |
StreamWriter.newBuilder(String streamName,
BigQueryWriteClient client) |
|
StreamWriter.Builder |
StreamWriter.Builder.setChannelProvider(com.google.api.gax.rpc.TransportChannelProvider channelProvider) |
ChannelProvider to use to create Channels, which must point at Cloud BigQuery Storage
API endpoint.
|
StreamWriter.Builder |
StreamWriter.Builder.setCompressorName(String compressorName) |
|
StreamWriter.Builder |
StreamWriter.Builder.setCredentialsProvider(com.google.api.gax.core.CredentialsProvider credentialsProvider) |
CredentialsProvider to use to create Credentials to authenticate calls.
|
StreamWriter.Builder |
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.
|
StreamWriter.Builder |
StreamWriter.Builder.setEnableConnectionPool(boolean enableConnectionPool) |
Enable multiplexing for this writer.
|
StreamWriter.Builder |
StreamWriter.Builder.setEndpoint(String endpoint) |
Gives the ability to override the gRPC endpoint.
|
StreamWriter.Builder |
StreamWriter.Builder.setExecutorProvider(com.google.api.gax.core.ExecutorProvider executorProvider) |
ExecutorProvider to use to create Executor to run background jobs.
|
StreamWriter.Builder |
StreamWriter.Builder.setLimitExceededBehavior(com.google.api.gax.batching.FlowController.LimitExceededBehavior limitExceededBehavior) |
Sets the limit exceeded behavior.
|
StreamWriter.Builder |
StreamWriter.Builder.setLocation(String location) |
Location of the table this stream writer is targeting.
|
StreamWriter.Builder |
StreamWriter.Builder.setMaxInflightBytes(long value) |
|
StreamWriter.Builder |
StreamWriter.Builder.setMaxInflightRequests(long value) |
|
StreamWriter.Builder |
StreamWriter.Builder.setMaxRetryDuration(Duration maxRetryDuration) |
|
StreamWriter.Builder |
StreamWriter.Builder.setTraceId(String traceId) |
Sets traceId for debuging purpose.
|
StreamWriter.Builder |
StreamWriter.Builder.setWriterSchema(ProtoSchema writerSchema) |
Sets the proto schema of the rows.
|