com.continuent.tungsten.replicator.event
Class ReplDBMSHeaderData

java.lang.Object
  com.continuent.tungsten.replicator.event.ReplDBMSHeaderData

All Implemented Interfaces:

ReplDBMSHeader

public class ReplDBMSHeaderData
extends java.lang.Object
implements ReplDBMSHeader

An implementation of replicator header information used to track position.

Version:

1.0

Author:

Robert Hodges

Constructor Summary

ReplDBMSHeaderData(long seqno, short fragno, boolean lastFrag, java.lang.String sourceId, long epochNumber, java.lang.String eventId, java.lang.String shardId, java.sql.Timestamp extractedTstamp, long latency)
Create header instance from component parts.

ReplDBMSHeaderData(ReplDBMSHeader event)

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.

Methods inherited from class java.lang.Object

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

Constructor Detail

ReplDBMSHeaderData

public ReplDBMSHeaderData(long seqno,
                          short fragno,
                          boolean lastFrag,
                          java.lang.String sourceId,
                          long epochNumber,
                          java.lang.String eventId,
                          java.lang.String shardId,
                          java.sql.Timestamp extractedTstamp,
                          long latency)

Create header instance from component parts.

ReplDBMSHeaderData

public ReplDBMSHeaderData(ReplDBMSHeader event)

Method Detail

getSeqno

public long getSeqno()

Description copied from interface: ReplDBMSHeader

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

Specified by:

getSeqno in interface ReplDBMSHeader

getEventId

public java.lang.String getEventId()

Description copied from interface: ReplDBMSHeader

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

Specified by:

getEventId in interface ReplDBMSHeader

getEpochNumber

public long getEpochNumber()

Description copied from interface: ReplDBMSHeader

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

Specified by:

getEpochNumber in interface ReplDBMSHeader

getFragno

public short getFragno()

Description copied from interface: ReplDBMSHeader

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

Specified by:

getFragno in interface ReplDBMSHeader

getLastFrag

public boolean getLastFrag()

Description copied from interface: ReplDBMSHeader

Returns true if this fragment is the last one.

Specified by:

getLastFrag in interface ReplDBMSHeader

getSourceId

public java.lang.String getSourceId()

Description copied from interface: ReplDBMSHeader

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

Specified by:

getSourceId in interface ReplDBMSHeader

getShardId

public java.lang.String getShardId()

Description copied from interface: ReplDBMSHeader

Returns the shard ID for this transaction.

Specified by:

getShardId in interface ReplDBMSHeader

getExtractedTstamp

public java.sql.Timestamp getExtractedTstamp()

Description copied from interface: ReplDBMSHeader

Returns the extractedTstamp value.

Specified by:

getExtractedTstamp in interface ReplDBMSHeader

getAppliedLatency

public long getAppliedLatency()

Specified by:

getAppliedLatency in interface ReplDBMSHeader