co.cask.cdap.messaging.store

Interface PayloadTable.Entry

All Known Implementing Classes:

ImmutablePayloadTableEntry

Enclosing interface:

PayloadTable

public static interface PayloadTable.Entry

Represents an entry (row) in the payload table.

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.

Method Detail

getTopicId

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

Returns the topic id that the entry belongs to.

getGeneration

int getGeneration()

Returns the generation id of the topic.

getPayload

byte[] getPayload()

Returns the message payload.

getTransactionWritePointer

long getTransactionWritePointer()

Returns the transaction write pointer for storing the payload.

getPayloadWriteTimestamp

long getPayloadWriteTimestamp()

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

getPayloadSequenceId

short getPayloadSequenceId()

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