com.continuent.tungsten.replicator.pipeline
Class ShardProgress

java.lang.Object
  com.continuent.tungsten.replicator.pipeline.ShardProgress

public class ShardProgress
extends java.lang.Object

Tracks statistics for an individual shard, which is identified by a shard ID.

Version:

1.0

Author:

Robert Hodges

Method Summary

ShardProgress	clone() Returns a shallow copy of this instance.
long	getApplyLatencyMillis() Return apply latency in milliseconds.
double	getApplyLatencySeconds() Return apply latency in seconds.
long	getEventCount()
java.lang.String	getLastEventId()
long	getLastSeqno()
java.lang.String	getShardId()
java.lang.String	getStageName()
void	incrementEventCount()
void	setApplyLatencyMillis(long applyLatencyMillis)
void	setEventCount(long eventCount)
void	setLastEventId(java.lang.String lastEventId)
void	setLastSeqno(long seqno)

Methods inherited from class java.lang.Object

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

Method Detail

getShardId

public java.lang.String getShardId()

getStageName

public java.lang.String getStageName()

getLastSeqno

public long getLastSeqno()

setLastSeqno

public void setLastSeqno(long seqno)

getLastEventId

public java.lang.String getLastEventId()

setLastEventId

public void setLastEventId(java.lang.String lastEventId)

getEventCount

public long getEventCount()

setEventCount

public void setEventCount(long eventCount)

incrementEventCount

public void incrementEventCount()

getApplyLatencyMillis

public long getApplyLatencyMillis()

Return apply latency in milliseconds. Sub-zero values are rounded to 0.

getApplyLatencySeconds

public double getApplyLatencySeconds()

Return apply latency in seconds.

setApplyLatencyMillis

public void setApplyLatencyMillis(long applyLatencyMillis)

clone

public ShardProgress clone()

Returns a shallow copy of this instance.

Overrides:

clone in class java.lang.Object