alluxio.master.journal.raft

Class JournalEntryCommand

java.lang.Object

alluxio.master.journal.raft.JournalEntryCommand

All Implemented Interfaces:

io.atomix.catalyst.serializer.CatalystSerializable, io.atomix.copycat.Command<Void>, io.atomix.copycat.Operation<Void>, Serializable

public class JournalEntryCommand
extends Object
implements io.atomix.copycat.Command<Void>, io.atomix.catalyst.serializer.CatalystSerializable

Command for writing an arbitrary journal entry. Journal entries are serialized by writing their size as an integer, followed by their bytes serialized in protocol buffer format.

See Also:

Serialized Form

Nested Class Summary

Nested classes/interfaces inherited from interface io.atomix.copycat.Command

io.atomix.copycat.Command.CompactionMode

Constructor Summary

Constructors

Constructor and Description
JournalEntryCommand() No-arg constructor for use by Catalyst deserialization.
JournalEntryCommand(Journal.JournalEntry entry) Constructs a JournalEntryCommand for a journal entry.

Method Summary

Modifier and Type	Method and Description
byte[]	getSerializedJournalEntry()
int	getSize()
void	readObject(io.atomix.catalyst.buffer.BufferInput<?> buffer, io.atomix.catalyst.serializer.Serializer serializer)
void	writeObject(io.atomix.catalyst.buffer.BufferOutput<?> buffer, io.atomix.catalyst.serializer.Serializer serializer)

Methods inherited from class java.lang.Object

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

Methods inherited from interface io.atomix.copycat.Command

compaction

Constructor Detail

JournalEntryCommand

public JournalEntryCommand()

No-arg constructor for use by Catalyst deserialization.

JournalEntryCommand

public JournalEntryCommand(Journal.JournalEntry entry)

Constructs a JournalEntryCommand for a journal entry.

Parameters:

entry - the journal entry

Method Detail

writeObject

public void writeObject(io.atomix.catalyst.buffer.BufferOutput<?> buffer,
                        io.atomix.catalyst.serializer.Serializer serializer)

Specified by:

writeObject in interface io.atomix.catalyst.serializer.CatalystSerializable

readObject

public void readObject(io.atomix.catalyst.buffer.BufferInput<?> buffer,
                       io.atomix.catalyst.serializer.Serializer serializer)

Specified by:

readObject in interface io.atomix.catalyst.serializer.CatalystSerializable

getSize

public int getSize()

Returns:

the serialized size of the journal entry

getSerializedJournalEntry

public byte[] getSerializedJournalEntry()

Returns:

the serialized journal entry