com.bigdata.ha.msg

Interface IHAWriteMessage

All Superinterfaces:

IHAMessage, IHAWriteMessageBase, Serializable

All Known Implementing Classes:

HAWriteMessage

public interface IHAWriteMessage
extends IHAWriteMessageBase

A message carrying RMI metadata about a payload which will be replicated using a socket-level transfer facility.

Author:

Bryan Thompson

Method Summary

Methods

Modifier and Type	Method and Description
ByteBuffer	expand(ByteBuffer bin) Applies associated IRecordCompressor (if any) to decompress the data
long	getCommitCounter() The commit counter for the opening root block associated with the write set for this message.
String	getCompressorKey() Return the associated IRecordCompressor key (if any).
long	getFileExtent() The length of the backing file on the disk.
long	getFirstOffset() The file offset at which the data will be written (WORM only or for Rebuild request).
long	getLastCommitTime() The commit time associated with this message.
long	getQuorumToken() The quorum token for which this message is valid.
int	getReplicationFactor() The replication factor for the quorum leader.
long	getSequence() The write cache buffer sequence number (reset to ZERO (0) for the first message after each commit and incremented for each buffer sent by the leader).
StoreTypeEnum	getStoreType() The type of backing store (RW or WORM).
UUID	getUUID() The UUID of the store to which this message belongs.

Methods inherited from interface com.bigdata.ha.msg.IHAWriteMessageBase

getChk, getSize

Method Detail

getUUID

UUID getUUID()

The UUID of the store to which this message belongs.

getCommitCounter

long getCommitCounter()

The commit counter for the opening root block associated with the write set for this message.

getLastCommitTime

long getLastCommitTime()

The commit time associated with this message.

getSequence

long getSequence()

The write cache buffer sequence number (reset to ZERO (0) for the first message after each commit and incremented for each buffer sent by the leader).

expand

ByteBuffer expand(ByteBuffer bin)

Applies associated IRecordCompressor (if any) to decompress the data

getCompressorKey

String getCompressorKey()

Return the associated IRecordCompressor key (if any).

getStoreType

StoreTypeEnum getStoreType()

The type of backing store (RW or WORM).

getQuorumToken

long getQuorumToken()

The quorum token for which this message is valid.

getReplicationFactor

int getReplicationFactor()

The replication factor for the quorum leader.

getFileExtent

long getFileExtent()

The length of the backing file on the disk.

getFirstOffset

long getFirstOffset()

The file offset at which the data will be written (WORM only or for Rebuild request).