Class StreamWriter.SingleConnectionOrConnectionPool (3.6.1)

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

ofSingleConnection(ConnectionWorker connection)

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

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()