alluxio.master.journal

Class JournalEntryStreamReader

java.lang.Object

alluxio.master.journal.JournalEntryStreamReader

All Implemented Interfaces:

Closeable, AutoCloseable

public class JournalEntryStreamReader
extends Object
implements Closeable

Class for reading journal entries from an input stream.

Constructor Summary

Constructors

Constructor and Description
JournalEntryStreamReader(InputStream stream)

Method Summary

Modifier and Type	Method and Description
void	close()
Journal.JournalEntry	readEntry() Reads a journal entry from the input stream.

Methods inherited from class java.lang.Object

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

Constructor Detail

JournalEntryStreamReader

public JournalEntryStreamReader(InputStream stream)

Parameters:

stream - the stream to read from

Method Detail

readEntry

public Journal.JournalEntry readEntry()
                               throws IOException

Reads a journal entry from the input stream.

Returns:

the journal entry, null if no journal entry is found

Throws:

IOException

close

public void close()
           throws IOException

Specified by:

close in interface Closeable

Specified by:

close in interface AutoCloseable

Throws:

IOException