org.apache.reef.io.storage

Class FramingInputStream

java.lang.Object

java.io.InputStream

java.io.FilterInputStream

java.io.DataInputStream

org.apache.reef.io.storage.FramingInputStream

All Implemented Interfaces:

Closeable, DataInput, AutoCloseable, Iterable<byte[]>

public class FramingInputStream
extends DataInputStream
implements Iterable<byte[]>

Constructor Summary

Constructors

Constructor and Description
FramingInputStream(InputStream in)

Method Summary

Methods

Modifier and Type	Method and Description
Iterator<byte[]>	iterator()
byte[]	readFrame()

Methods inherited from class java.io.DataInputStream

read, read, readBoolean, readByte, readChar, readDouble, readFloat, readFully, readFully, readInt, readLine, readLong, readShort, readUnsignedByte, readUnsignedShort, readUTF, readUTF, skipBytes

Methods inherited from class java.io.FilterInputStream

available, close, mark, markSupported, read, reset, skip

Methods inherited from class java.lang.Object

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

Constructor Detail

FramingInputStream

public FramingInputStream(InputStream in)

Method Detail

readFrame

public byte[] readFrame()
                 throws IOException

Throws:

IOException

iterator

public Iterator<byte[]> iterator()

Specified by:

iterator in interface Iterable<byte[]>