Class JsonStreamWriter.Builder (3.17.2)

public static final class JsonStreamWriter.Builder

Inheritance

Object > JsonStreamWriter.Builder

Inherited Members

Object.clone()

Object.equals(Object)

Object.finalize()

Object.getClass()

Object.hashCode()

Object.notify()

Object.notifyAll()

Object.toString()

Object.wait()

Object.wait(long)

Object.wait(long,int)

Methods

build()

public JsonStreamWriter build()

Builds JsonStreamWriter

Returns
Type	Description
`JsonStreamWriter`	JsonStreamWriter

Exceptions
Type	Description
`DescriptorValidationException`
`IllegalArgumentException`
`IOException`
`InterruptedException`

getStreamName()

public String getStreamName()

Stream name on the builder.

Returns
Type	Description
`String`	Builder

setChannelProvider(TransportChannelProvider channelProvider)

public JsonStreamWriter.Builder setChannelProvider(TransportChannelProvider channelProvider)

Setter for the underlying StreamWriter's TransportChannelProvider.

Parameter
Name	Description
`channelProvider`	`TransportChannelProvider`

Returns
Type	Description
`JsonStreamWriter.Builder`	Builder

setCompressorName(String compressorName)

public JsonStreamWriter.Builder 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
`JsonStreamWriter.Builder`	Builder

setCredentialsProvider(CredentialsProvider credentialsProvider)

public JsonStreamWriter.Builder setCredentialsProvider(CredentialsProvider credentialsProvider)

Setter for the underlying StreamWriter's CredentialsProvider.

Parameter
Name	Description
`credentialsProvider`	`CredentialsProvider`

Returns
Type	Description
`JsonStreamWriter.Builder`	Builder

setDefaultMissingValueInterpretation(AppendRowsRequest.MissingValueInterpretation defaultMissingValueInterpretation)

public JsonStreamWriter.Builder setDefaultMissingValueInterpretation(AppendRowsRequest.MissingValueInterpretation defaultMissingValueInterpretation)

Sets the default missing value interpretation value if the column is not presented in the missing_value_interpretations map.

If this value is set to DEFAULT_VALUE, we will always populate default value if the field is missing from json and default value is defined in the column.

If this value is set to NULL_VALUE, we will always not populate default value.

Parameter
Name	Description
`defaultMissingValueInterpretation`	`AppendRowsRequest.MissingValueInterpretation`

Returns
Type	Description
`JsonStreamWriter.Builder`

setEnableConnectionPool(boolean enableConnectionPool)

public JsonStreamWriter.Builder setEnableConnectionPool(boolean enableConnectionPool)

Enables a static shared bidi-streaming connection pool that would dynamically scale up connections based on backlog within each individual connection. A single table's traffic might be splitted into multiple connections if needed. Different tables' traffic can also be multiplexed within the same connection.

 Each connection pool would have a upper limit (default to 20) and lower limit (default to
 2) for the number of active connections. This parameter can be tuned via a static method
 exposed on ConnectionWorkerPool.

 Example:
 ConnectionWorkerPool.setOptions(
     Settings.builder().setMinConnectionsPerRegion(4).setMaxConnectionsPerRegion(10).build());

Parameter
Name	Description
`enableConnectionPool`	`boolean`

Returns
Type	Description
`JsonStreamWriter.Builder`	Builder

setEnableLatencyProfiler(boolean enableLatencyProfiler)

public JsonStreamWriter.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
`enableLatencyProfiler`	`boolean`

Returns
Type	Description
`JsonStreamWriter.Builder`

setEnableOpenTelemetry(boolean enableOpenTelemetry)

public JsonStreamWriter.Builder setEnableOpenTelemetry(boolean enableOpenTelemetry)

Enable generation of metrics for OpenTelemetry.

Parameter
Name	Description
`enableOpenTelemetry`	`boolean`

Returns
Type	Description
`JsonStreamWriter.Builder`

setEndpoint(String endpoint)

public JsonStreamWriter.Builder setEndpoint(String endpoint)

Setter for the underlying StreamWriter's Endpoint.

Parameter
Name	Description
`endpoint`	`String`

Returns
Type	Description
`JsonStreamWriter.Builder`	Builder

setExecutorProvider(ExecutorProvider executorProvider)

public JsonStreamWriter.Builder setExecutorProvider(ExecutorProvider executorProvider)

Setter for the underlying StreamWriter's ExecutorProvider.

Parameter
Name	Description
`executorProvider`	`ExecutorProvider`

Returns
Type	Description
`JsonStreamWriter.Builder`

setFlowControlSettings(FlowControlSettings flowControlSettings)

public JsonStreamWriter.Builder setFlowControlSettings(FlowControlSettings flowControlSettings)

Setter for the underlying StreamWriter's FlowControlSettings.

Parameter
Name	Description
`flowControlSettings`	`FlowControlSettings`

Returns
Type	Description
`JsonStreamWriter.Builder`	Builder

setIgnoreUnknownFields(boolean ignoreUnknownFields)

public JsonStreamWriter.Builder setIgnoreUnknownFields(boolean ignoreUnknownFields)

Setter for a ignoreUnkownFields, if true, unknown Json fields to BigQuery will be ignored instead of error out.

Parameter
Name	Description
`ignoreUnknownFields`	`boolean`

Returns
Type	Description
`JsonStreamWriter.Builder`	Builder

setLocation(String location)

public JsonStreamWriter.Builder 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
`JsonStreamWriter.Builder`	Builder

setMissingValueInterpretationMap(Map<String,AppendRowsRequest.MissingValueInterpretation> missingValueInterpretationMap)

public JsonStreamWriter.Builder setMissingValueInterpretationMap(Map<String,AppendRowsRequest.MissingValueInterpretation> missingValueInterpretationMap)

Sets the missing value interpretation map for the JsonStreamWriter. The input missingValueInterpretationMap is used for all append requests unless otherwise changed.

Parameter
Name	Description
`missingValueInterpretationMap`	`Map<String,MissingValueInterpretation>` the missing value interpretation map used by the JsonStreamWriter.

Returns
Type	Description
`JsonStreamWriter.Builder`	Builder

setReconnectAfter10M(boolean reconnectAfter10M)

public JsonStreamWriter.Builder setReconnectAfter10M(boolean reconnectAfter10M)

This parameter is not used. It will be removed soon.

Parameter
Name	Description
`reconnectAfter10M`	`boolean`

Returns
Type	Description
`JsonStreamWriter.Builder`

setRetrySettings(RetrySettings retrySettings)

public JsonStreamWriter.Builder setRetrySettings(RetrySettings retrySettings)

Enable client lib automatic retries on request level errors.

Immediate Retry code: ABORTED, UNAVAILABLE, CANCELLED, INTERNAL, DEADLINE_EXCEEDED Backoff Retry code: RESOURCE_EXHAUSTED

Example: RetrySettings retrySettings = RetrySettings.newBuilder() .setInitialRetryDelay(Duration.ofMillis(500)) // applies to backoff retry .setRetryDelayMultiplier(1.1) // applies to backoff retry .setMaxAttempts(5) // applies to both retries .setMaxRetryDelay(Duration.ofMinutes(1)) // applies to backoff retry .build();

Parameter
Name	Description
`retrySettings`	`RetrySettings`

Returns
Type	Description
`JsonStreamWriter.Builder`

setTraceId(String traceId)

public JsonStreamWriter.Builder setTraceId(String traceId)

Setter for a traceId to help identify traffic origin.

Parameter
Name	Description
`traceId`	`String`

Returns
Type	Description
`JsonStreamWriter.Builder`	Builder

Class JsonStreamWriter.Builder (3.17.2) Stay organized with collections Save and categorize content based on your preferences.