org.apache.beam.sdk.io.gcp.bigquery

Interface BigQueryServices.BigQueryServerStream<T>

All Superinterfaces:

java.lang.Iterable<T>, java.io.Serializable

All Known Implementing Classes:

FakeBigQueryServices.FakeBigQueryServerStream

Enclosing interface:

BigQueryServices

public static interface BigQueryServices.BigQueryServerStream<T>
extends java.lang.Iterable<T>, java.io.Serializable

Container for reading data from streaming endpoints.

An implementation does not need to be thread-safe.

Method Summary

Modifier and Type	Method and Description
void	cancel() Cancels the stream, releasing any client- and server-side resources.

Methods inherited from interface java.lang.Iterable

forEach, iterator, spliterator

Method Detail

cancel

void cancel()

Cancels the stream, releasing any client- and server-side resources. This method may be called multiple times and from any thread.