alluxio.master.journalv0

Class ProtoBufJournalFormatter

java.lang.Object

alluxio.master.journalv0.ProtoBufJournalFormatter

All Implemented Interfaces:

JournalFormatter

@ThreadSafe
public final class ProtoBufJournalFormatter
extends Object
implements JournalFormatter

Reads and writes protocol buffer journal entries. The entries contain headers describing their length. This framing is handled entirely by AbstractMessageLite.writeDelimitedTo(OutputStream) and Journal.JournalEntry.parseDelimitedFrom(InputStream). This class is thread-safe.

Nested Class Summary

Nested classes/interfaces inherited from interface alluxio.master.journalv0.JournalFormatter

JournalFormatter.Factory

Constructor Summary

Constructors

Constructor and Description
ProtoBufJournalFormatter() Constructs a new ProtoBufJournalFormatter.

Method Summary

Modifier and Type	Method and Description
JournalInputStream	deserialize(InputStream inputStream) Returns a JournalInputStream from the given input stream.
void	serialize(Journal.JournalEntry entry, OutputStream outputStream) Serializes the given entry and writes it to the given output stream.

Methods inherited from class java.lang.Object

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

Constructor Detail

ProtoBufJournalFormatter

public ProtoBufJournalFormatter()

Constructs a new ProtoBufJournalFormatter.

Method Detail

serialize

public void serialize(Journal.JournalEntry entry,
                      OutputStream outputStream)
               throws IOException

Description copied from interface: JournalFormatter

Serializes the given entry and writes it to the given output stream.

Specified by:

serialize in interface JournalFormatter

Parameters:

entry - The journal entry to serialize

outputStream - the output stream to serialize the entry to

Throws:

IOException

deserialize

public JournalInputStream deserialize(InputStream inputStream)
                               throws IOException

Description copied from interface: JournalFormatter

Returns a JournalInputStream from the given input stream. The returned input stream produces a stream of Journal.JournalEntry objects.

Specified by:

deserialize in interface JournalFormatter

Parameters:

inputStream - The input stream to deserialize

Returns:

a JournalInputStream for reading all the journal entries in the given input stream.

Throws:

IOException