Class StreamWriter.SingleConnectionOrConnectionPool (2.45.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
NameDescription
connectionPoolConnectionWorkerPool
Returns
TypeDescription
StreamWriter.SingleConnectionOrConnectionPool

ofSingleConnection(ConnectionWorker connection)

public static StreamWriter.SingleConnectionOrConnectionPool ofSingleConnection(ConnectionWorker connection)
Parameter
NameDescription
connectioncom.google.cloud.bigquery.storage.v1.ConnectionWorker
Returns
TypeDescription
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
NameDescription
streamWriterStreamWriter
protoRowsProtoRows
offsetlong
Returns
TypeDescription
ApiFuture<AppendRowsResponse>

close(StreamWriter streamWriter)

public void close(StreamWriter streamWriter)
Parameter
NameDescription
streamWriterStreamWriter

connectionWorker()

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

connectionWorkerPool()

public abstract ConnectionWorkerPool connectionWorkerPool()
Returns
TypeDescription
ConnectionWorkerPool

getKind()

public abstract StreamWriter.SingleConnectionOrConnectionPool.Kind getKind()
Returns
TypeDescription
StreamWriter.SingleConnectionOrConnectionPool.Kind