alluxio.master.journal.checkpoint

Class CheckpointInputStream

java.lang.Object

java.io.InputStream

java.io.FilterInputStream

java.io.DataInputStream

alluxio.master.journal.checkpoint.CheckpointInputStream

All Implemented Interfaces:

Closeable, DataInput, AutoCloseable

Direct Known Subclasses:

OptimizedCheckpointInputStream

public class CheckpointInputStream
extends DataInputStream

Input stream for reading checkpoints. The stream reads the checkpoint version number.

See Also:

CheckpointOutputStream

Field Summary

Fields inherited from class java.io.FilterInputStream

in

Constructor Summary

Constructors

Constructor and Description
CheckpointInputStream(InputStream in)

Method Summary

Modifier and Type	Method and Description
CheckpointType	getType()

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

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

Constructor Detail

CheckpointInputStream

public CheckpointInputStream(InputStream in)
                      throws IOException

Parameters:

in - the underlying stream to read from

Throws:

IOException

Method Detail

getType

public CheckpointType getType()

Returns:

the checkpoint type