alluxio.master.journal.checkpoint

Class JournalCheckpointFormat.JournalCheckpointReader

java.lang.Object

alluxio.master.journal.checkpoint.JournalCheckpointFormat.JournalCheckpointReader

All Implemented Interfaces:

CheckpointFormat.CheckpointReader

Enclosing class:

JournalCheckpointFormat

public static class JournalCheckpointFormat.JournalCheckpointReader
extends Object
implements CheckpointFormat.CheckpointReader

Reads journal entries from a checkpoint stream. The underlying stream will not be closed.

Constructor Summary

Constructors

Constructor and Description
JournalCheckpointReader(CheckpointInputStream in)

Method Summary

Modifier and Type	Method and Description
Optional<Journal.JournalEntry>	nextEntry()

Methods inherited from class java.lang.Object

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

Constructor Detail

JournalCheckpointReader

public JournalCheckpointReader(CheckpointInputStream in)

Parameters:

in - a checkpoint stream to read from

Method Detail

nextEntry

public Optional<Journal.JournalEntry> nextEntry()
                                         throws IOException

Returns:

the next journal entry, or empty if we've reached the end

Throws:

IOException