Class StreamConnection (2.27.0)

public class StreamConnection

StreamConnection is responsible for writing requests to a GRPC bidirecional connection.

StreamWriter creates a connection. Two callback functions are necessary: request_callback and done_callback. Request callback is used for every request, and done callback is used to notify the user that the connection is closed and no more callbacks will be received from this connection.

The stream writer will accept all the requests without flow control, and makes the callbacks in receiving order.

It's user's responsibility to do the flow control and maintain the lifetime of the requests.

Inheritance

java.lang.Object > StreamConnection

Constructors

StreamConnection(BigQueryWriteClient client, StreamConnection.RequestCallback requestCallback, StreamConnection.DoneCallback doneCallback)

public StreamConnection(BigQueryWriteClient client, StreamConnection.RequestCallback requestCallback, StreamConnection.DoneCallback doneCallback)
Parameters
NameDescription
clientBigQueryWriteClient
requestCallbackStreamConnection.RequestCallback
doneCallbackStreamConnection.DoneCallback

Methods

close()

public void close()

Close the bi-directional stream connection.

send(AppendRowsRequest request)

public void send(AppendRowsRequest request)

Sends a request to the bi-directional stream connection.

Parameter
NameDescription
requestAppendRowsRequest

request to send.