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

Interface BigQueryServices.BigQueryServerStream<T>

All Superinterfaces:
Iterable<T>, Serializable
All Known Implementing Classes:
FakeBigQueryServices.FakeBigQueryServerStream
Enclosing interface:
BigQueryServices
public static interface BigQueryServices.BigQueryServerStream<T> extends Iterable<T>, Serializable
Container for reading data from streaming endpoints.

An implementation does not need to be thread-safe.

  • Method Summary

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

    Methods inherited from interface java.lang.Iterable

    forEach, iterator, spliterator

  • Method Details

    • cancel

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