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:

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

Enclosing class:

FakeBigQueryServices

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

An implementation of 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 and Description
FakeBigQueryServerStream(java.util.List<T> items)

Method Summary

Modifier and Type	Method and Description
void	cancel() Cancels the stream, releasing any client- and server-side resources.
java.util.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 Detail

FakeBigQueryServerStream

public FakeBigQueryServerStream(java.util.List<T> items)

Method Detail

iterator

public java.util.Iterator<T> iterator()

Specified by:

iterator in interface java.lang.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>