Class StreamWriter.SingleConnectionOrConnectionPool (3.6.0)

public abstract static class StreamWriter.SingleConnectionOrConnectionPool

When in single table mode, append directly to connectionWorker. Otherwise append to connection pool in multiplexing mode.

Inheritance

java.lang.Object > StreamWriter.SingleConnectionOrConnectionPool

Static Methods

ofConnectionPool(ConnectionWorkerPool connectionPool)

public static StreamWriter.SingleConnectionOrConnectionPool ofConnectionPool(ConnectionWorkerPool connectionPool)
Parameter
Name Description
connectionPool ConnectionWorkerPool
Returns
Type Description
StreamWriter.SingleConnectionOrConnectionPool

ofSingleConnection(ConnectionWorker connection)

public static StreamWriter.SingleConnectionOrConnectionPool ofSingleConnection(ConnectionWorker connection)
Parameter
Name Description
connection com.google.cloud.bigquery.storage.v1.ConnectionWorker
Returns
Type Description
StreamWriter.SingleConnectionOrConnectionPool

Constructors

SingleConnectionOrConnectionPool()

public SingleConnectionOrConnectionPool()

Methods

append(StreamWriter streamWriter, ProtoRows protoRows, long offset)

public ApiFuture<AppendRowsResponse> append(StreamWriter streamWriter, ProtoRows protoRows, long offset)
Parameters
Name Description
streamWriter StreamWriter
protoRows ProtoRows
offset long
Returns
Type Description
ApiFuture<AppendRowsResponse>

close(StreamWriter streamWriter)

public void close(StreamWriter streamWriter)
Parameter
Name Description
streamWriter StreamWriter

connectionWorker()

public abstract ConnectionWorker connectionWorker()
Returns
Type Description
com.google.cloud.bigquery.storage.v1.ConnectionWorker

connectionWorkerPool()

public abstract ConnectionWorkerPool connectionWorkerPool()
Returns
Type Description
ConnectionWorkerPool

getKind()

public abstract StreamWriter.SingleConnectionOrConnectionPool.Kind getKind()
Returns
Type Description
StreamWriter.SingleConnectionOrConnectionPool.Kind