static <T> SchemaAwareStreamWriter.Builder<T> |
SchemaAwareStreamWriter.newBuilder(String streamOrTableName,
BigQueryWriteClient client,
ToProtoConverter<T> toProtoConverter) |
newBuilder that constructs a SchemaAwareStreamWriter builder with TableSchema being initialized
by StreamWriter by default.
|
static <T> SchemaAwareStreamWriter.Builder<T> |
SchemaAwareStreamWriter.newBuilder(String streamOrTableName,
TableSchema tableSchema,
BigQueryWriteClient client,
ToProtoConverter<T> toProtoConverter) |
newBuilder that constructs a SchemaAwareStreamWriter builder.
|
static <T> SchemaAwareStreamWriter.Builder<T> |
SchemaAwareStreamWriter.newBuilder(String streamOrTableName,
TableSchema tableSchema,
ToProtoConverter<T> toProtoConverter) |
newBuilder that constructs a SchemaAwareStreamWriter builder with BigQuery client being
initialized by StreamWriter by default.
|
SchemaAwareStreamWriter.Builder<T> |
SchemaAwareStreamWriter.Builder.setChannelProvider(com.google.api.gax.rpc.TransportChannelProvider channelProvider) |
Setter for the underlying StreamWriter's TransportChannelProvider.
|
SchemaAwareStreamWriter.Builder<T> |
SchemaAwareStreamWriter.Builder.setCompressorName(String compressorName) |
Sets the compression to use for the calls.
|
SchemaAwareStreamWriter.Builder<T> |
SchemaAwareStreamWriter.Builder.setCredentialsProvider(com.google.api.gax.core.CredentialsProvider credentialsProvider) |
Setter for the underlying StreamWriter's CredentialsProvider.
|
SchemaAwareStreamWriter.Builder |
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.
|
SchemaAwareStreamWriter.Builder<T> |
SchemaAwareStreamWriter.Builder.setEnableConnectionPool(boolean enableConnectionPool) |
Enable multiplexing for this writer.
|
SchemaAwareStreamWriter.Builder<T> |
SchemaAwareStreamWriter.Builder.setEndpoint(String endpoint) |
Setter for the underlying StreamWriter's Endpoint.
|
SchemaAwareStreamWriter.Builder<T> |
SchemaAwareStreamWriter.Builder.setExecutorProvider(com.google.api.gax.core.ExecutorProvider executorProvider) |
Setter for the underlying StreamWriter's ExecutorProvider.
|
SchemaAwareStreamWriter.Builder<T> |
SchemaAwareStreamWriter.Builder.setFlowControlSettings(com.google.api.gax.batching.FlowControlSettings flowControlSettings) |
Setter for the underlying StreamWriter's FlowControlSettings.
|
SchemaAwareStreamWriter.Builder<T> |
SchemaAwareStreamWriter.Builder.setIgnoreUnknownFields(boolean ignoreUnknownFields) |
Setter for a ignoreUnknownFields, if true, unknown fields to BigQuery will be ignored instead
of error out.
|
SchemaAwareStreamWriter.Builder<T> |
SchemaAwareStreamWriter.Builder.setLocation(String location) |
Location of the table this stream writer is targeting.
|
SchemaAwareStreamWriter.Builder<T> |
SchemaAwareStreamWriter.Builder.setTraceId(String traceId) |
Setter for a traceId to help identify traffic origin.
|
SchemaAwareStreamWriter.Builder<T> |
SchemaAwareStreamWriter.Builder.setTraceIdBase(String traceIdBase) |
Setter for a traceIdBase to help identify traffic origin.
|