alluxio.master.journal.checkpoint

Class OptimizedCheckpointInputStream

java.lang.Object

java.io.InputStream

java.io.FilterInputStream

java.io.DataInputStream

alluxio.master.journal.checkpoint.CheckpointInputStream

alluxio.master.journal.checkpoint.OptimizedCheckpointInputStream

All Implemented Interfaces:

Closeable, DataInput, AutoCloseable

public class OptimizedCheckpointInputStream
extends CheckpointInputStream

InputStream to read checkpoint files efficiently.

Field Summary

Fields inherited from class java.io.FilterInputStream

in

Constructor Summary

Constructors

Constructor and Description
OptimizedCheckpointInputStream(File file, MessageDigest digest)

Method Summary

Methods inherited from class alluxio.master.journal.checkpoint.CheckpointInputStream

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

OptimizedCheckpointInputStream

public OptimizedCheckpointInputStream(File file,
                                      MessageDigest digest)
                               throws IOException

Parameters:

file - where the checkpoint will be read from

digest - that verifies the file has not been corrupted

Throws:

IOException - propagates wrapped input stream exceptions