Class ConnectionWorkerPool (2.28.4)

public class ConnectionWorkerPool

Pool of connections to accept appends and distirbute to different connections.

Inheritance

java.lang.Object > ConnectionWorkerPool

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)

Static Methods

enableTestingLogic()

public static void enableTestingLogic()

Enable Test related logic.

setOptions(ConnectionWorkerPool.Settings settings)

public static void setOptions(ConnectionWorkerPool.Settings settings)

Sets static connection pool options.

Note: this method should be triggered prior to the construction of connection pool.

Parameter

Name	Description
`settings`	`ConnectionWorkerPool.Settings`

Constructors

ConnectionWorkerPool(long maxInflightRequests, long maxInflightBytes, Duration maxRetryDuration, FlowController.LimitExceededBehavior limitExceededBehavior, String traceId, BigQueryWriteSettings clientSettings)

public ConnectionWorkerPool(long maxInflightRequests, long maxInflightBytes, Duration maxRetryDuration, FlowController.LimitExceededBehavior limitExceededBehavior, String traceId, BigQueryWriteSettings clientSettings)

Parameters

Name	Description
`maxInflightRequests`	`long`
`maxInflightBytes`	`long`
`maxRetryDuration`	`Duration`
`limitExceededBehavior`	`LimitExceededBehavior`
`traceId`	`String`
`clientSettings`	`BigQueryWriteSettings`

Methods

append(StreamWriter streamWriter, ProtoRows rows)

public ApiFuture<AppendRowsResponse> append(StreamWriter streamWriter, ProtoRows rows)

Distributes the writing of a message to an underlying connection.

Parameters

Name	Description
`streamWriter`	`StreamWriter`
`rows`	`ProtoRows`

Returns

Type	Description
`ApiFuture<AppendRowsResponse>`

append(StreamWriter streamWriter, ProtoRows rows, long offset)

public ApiFuture<AppendRowsResponse> append(StreamWriter streamWriter, ProtoRows rows, long offset)

Distributes the writing of a message to an underlying connection.

Parameters

Name	Description
`streamWriter`	`StreamWriter`
`rows`	`ProtoRows`
`offset`	`long`

Returns

Type	Description
`ApiFuture<AppendRowsResponse>`

close(StreamWriter streamWriter)

public void close(StreamWriter streamWriter)

Reports the close of the given write stream.

The corresponding worker is not closed until there is no stream reference is targeting to that worker.

Parameter

Name	Description
`streamWriter`	`StreamWriter`

getInflightWaitSeconds(StreamWriter streamWriter)

public long getInflightWaitSeconds(StreamWriter streamWriter)

Fetch the wait seconds from corresponding worker.

Parameter

Name	Description
`streamWriter`	`StreamWriter`

Returns

Type	Description
`long`