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

ofSingleConnection(ConnectionWorker connection)

public static StreamWriter.SingleConnectionOrConnectionPool ofSingleConnection(ConnectionWorker connection)
Parameter
NameDescription
connectionConnectionWorker
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
ConnectionWorker

connectionWorkerPool()

public abstract ConnectionWorkerPool connectionWorkerPool()
Returns
TypeDescription
ConnectionWorkerPool

getKind()

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