Package com.google.cloud.bigquery.storage.v1beta2

Class StreamConnection

java.lang.Object

com.google.cloud.bigquery.storage.v1beta2.StreamConnection

public class StreamConnection
extends Object

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.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static interface	StreamConnection.DoneCallback	Invoked when server closes the connection.
static interface	StreamConnection.RequestCallback	Invoked when a response is received from the server.

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method	Description
void	close()	Close the bi-directional stream connection.
void	send(AppendRowsRequest request)	Sends a request to the bi-directional stream connection.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

StreamConnection

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

Method Detail

send

public void send(AppendRowsRequest request)

Sends a request to the bi-directional stream connection.

Parameters:

request - request to send.

close

public void close()

Close the bi-directional stream connection.