co.cask.cdap.messaging.store

Class ImmutablePayloadTableEntry

java.lang.Object

co.cask.cdap.messaging.store.ImmutablePayloadTableEntry

All Implemented Interfaces:

PayloadTable.Entry

public final class ImmutablePayloadTableEntry
extends Object
implements PayloadTable.Entry

An immutable implementation of PayloadTable.Entry.

Constructor Summary

Constructors

Constructor and Description
ImmutablePayloadTableEntry(byte[] row, byte[] payload)

Method Summary

Modifier and Type	Method and Description
int	getGeneration() Returns the generation id of the topic.
byte[]	getPayload() Returns the message payload.
short	getPayloadSequenceId() Returns the sequence id generated when the payload was written to the payload table.
long	getPayloadWriteTimestamp() Returns the timestamp in milliseconds when the payload was written to the payload table.
co.cask.cdap.proto.id.TopicId	getTopicId() Returns the topic id that the entry belongs to.
long	getTransactionWritePointer() Returns the transaction write pointer for storing the payload.

Methods inherited from class java.lang.Object

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

Constructor Detail

ImmutablePayloadTableEntry

public ImmutablePayloadTableEntry(byte[] row,
                                  byte[] payload)

Method Detail

getTopicId

public co.cask.cdap.proto.id.TopicId getTopicId()

Description copied from interface: PayloadTable.Entry

Returns the topic id that the entry belongs to.

Specified by:

getTopicId in interface PayloadTable.Entry

getGeneration

public int getGeneration()

Description copied from interface: PayloadTable.Entry

Returns the generation id of the topic.

Specified by:

getGeneration in interface PayloadTable.Entry

getPayload

public byte[] getPayload()

Description copied from interface: PayloadTable.Entry

Returns the message payload.

Specified by:

getPayload in interface PayloadTable.Entry

getTransactionWritePointer

public long getTransactionWritePointer()

Description copied from interface: PayloadTable.Entry

Returns the transaction write pointer for storing the payload.

Specified by:

getTransactionWritePointer in interface PayloadTable.Entry

getPayloadWriteTimestamp

public long getPayloadWriteTimestamp()

Description copied from interface: PayloadTable.Entry

Returns the timestamp in milliseconds when the payload was written to the payload table.

Specified by:

getPayloadWriteTimestamp in interface PayloadTable.Entry

getPayloadSequenceId

public short getPayloadSequenceId()

Description copied from interface: PayloadTable.Entry

Returns the sequence id generated when the payload was written to the payload table.

Specified by:

getPayloadSequenceId in interface PayloadTable.Entry