alluxio.master.journalv0

Interface JournalInputStream

All Superinterfaces:

AutoCloseable

public interface JournalInputStream
extends AutoCloseable

This input stream retrieves Journal.JournalEntry from journal checkpoints and journal logs.

Method Summary

Modifier and Type	Method and Description
void	close() Closes the stream.
long	getLatestSequenceNumber()
Journal.JournalEntry	read() Reads the next journal entry.

Method Detail

read

Journal.JournalEntry read()
                   throws IOException

Reads the next journal entry.

Returns:

the next Journal.JournalEntry in the stream, or null if the are no more entries

Throws:

IOException

close

void close()
    throws IOException

Closes the stream.

Specified by:

close in interface AutoCloseable

Throws:

IOException

getLatestSequenceNumber

long getLatestSequenceNumber()

Returns:

the sequence number of the latest journal entry seen in the stream