org.apache.beam.sdk.fn.stream

Class DataStreams.DataStreamDecoder<T>

java.lang.Object

org.apache.beam.sdk.fn.stream.DataStreams.DataStreamDecoder<T>

All Implemented Interfaces:

java.util.Iterator<T>

Enclosing class:

DataStreams

public static class DataStreams.DataStreamDecoder<T>
extends java.lang.Object
implements java.util.Iterator<T>

An adapter which converts an InputStream to an Iterator of T values using the specified Coder.

Note that this adapter follows the Beam Fn API specification for forcing values that decode consuming zero bytes to consuming exactly one byte.

Note that access to the underlying InputStream is lazy and will only be invoked on first access to next() or hasNext().

Constructor Summary

Constructors

Constructor and Description
DataStreamDecoder(Coder<T> coder, java.io.InputStream inputStream)

Method Summary

Modifier and Type	Method and Description
boolean	hasNext()
T	next()
void	remove()

Methods inherited from class java.lang.Object

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

Methods inherited from interface java.util.Iterator

forEachRemaining

Constructor Detail

DataStreamDecoder

public DataStreamDecoder(Coder<T> coder,
                         java.io.InputStream inputStream)

Method Detail

hasNext

public boolean hasNext()

Specified by:

hasNext in interface java.util.Iterator<T>

next

public T next()

Specified by:

next in interface java.util.Iterator<T>

remove

public void remove()

Specified by:

remove in interface java.util.Iterator<T>