com.continuent.tungsten.replicator.event
Interface ReplDBMSHeader

All Known Implementing Classes:

ReplDBMSEvent, ReplDBMSFilteredEvent, ReplDBMSHeaderData

public interface ReplDBMSHeader

Denotes header data used for replication. This is the core information used to remember the replication position so that restart is possible.

Version:

1.0

Author:

Robert Hodges

Method Summary

long	getAppliedLatency()
long	getEpochNumber() Returns the epoch number, a number that identifies a continuous sequence of events from the time a master goes online until it goes offline.
java.lang.String	getEventId() Returns the native event ID corresponding to this log sequence number.
java.sql.Timestamp	getExtractedTstamp() Returns the extractedTstamp value.
short	getFragno() Returns the event fragment number, a monotonically increasing whole number starting at 0.
boolean	getLastFrag() Returns true if this fragment is the last one.
long	getSeqno() Returns the log sequence number, a monotonically increasing whole number starting at 0 that denotes a single transaction.
java.lang.String	getShardId() Returns the shard ID for this transaction.
java.lang.String	getSourceId() Returns the ID of the data source from which this event was originally extracted.

Method Detail

getSeqno

long getSeqno()

Returns the log sequence number, a monotonically increasing whole number starting at 0 that denotes a single transaction.

getFragno

short getFragno()

Returns the event fragment number, a monotonically increasing whole number starting at 0.

getLastFrag

boolean getLastFrag()

Returns true if this fragment is the last one.

getSourceId

java.lang.String getSourceId()

Returns the ID of the data source from which this event was originally extracted.

getEpochNumber

long getEpochNumber()

Returns the epoch number, a number that identifies a continuous sequence of events from the time a master goes online until it goes offline.

getEventId

java.lang.String getEventId()

Returns the native event ID corresponding to this log sequence number.

getShardId

java.lang.String getShardId()

Returns the shard ID for this transaction.

getExtractedTstamp

java.sql.Timestamp getExtractedTstamp()

Returns the extractedTstamp value.

getAppliedLatency

long getAppliedLatency()