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

Class FakeBigQueryServices.FakeBigQueryServerStream<T>

java.lang.Object

org.apache.beam.sdk.io.gcp.testing.FakeBigQueryServices.FakeBigQueryServerStream<T>

All Implemented Interfaces:

Serializable, Iterable<T>, BigQueryServices.BigQueryServerStream<T>

Enclosing class:

FakeBigQueryServices

public static class FakeBigQueryServices.FakeBigQueryServerStream<T>
extends Object
implements BigQueryServices.BigQueryServerStream<T>

An implementation of BigQueryServices.BigQueryServerStream which takes a List as the Iterable to simulate a server stream. FakeBigQueryServerStream(java.util.List<T>) is a no-op.

See Also:

• Serialized Form

Constructor Summary

Constructors

Constructor	Description
FakeBigQueryServerStream(List<T> items)

Method Summary

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

Methods inherited from class java.lang.Object

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

Methods inherited from interface java.lang.Iterable

forEach, spliterator

Constructor Details

FakeBigQueryServerStream

public FakeBigQueryServerStream(List<T> items)

Method Details

iterator

public Iterator<T> iterator()

Specified by:

iterator in interface Iterable<T>

cancel

public void cancel()

Description copied from interface: BigQueryServices.BigQueryServerStream

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

Specified by:

cancel in interface BigQueryServices.BigQueryServerStream<T>