org.apache.hadoop.hbase.replication.regionserver

Class MetricsSink

java.lang.Object

org.apache.hadoop.hbase.replication.regionserver.MetricsSink

@InterfaceAudience.Private
public class MetricsSink
extends Object

This class is for maintaining the various replication statistics for a sink and publishing them through the metrics interfaces.

Field Summary

Fields

Modifier and Type	Field and Description
private long	lastTimestampForAge
private MetricsReplicationSinkSource	mss
private long	startTimestamp

Constructor Summary

Constructors

Constructor and Description
MetricsSink()

Method Summary

Modifier and Type	Method and Description
void	applyBatch(long batchSize) Convience method to change metrics when a batch of operations are applied.
void	applyBatch(long batchSize, long hfileSize) Convience method to change metrics when a batch of operations are applied.
long	getAgeOfLastAppliedOp() Get the Age of Last Applied Op
long	getAppliedOps() Gets the total number of OPs delivered to this sink.
long	getStartTimestamp() Gets the time stamp from when the Sink was initialized.
long	getTimestampOfLastAppliedOp() Get the TimestampOfLastAppliedOp.
long	getTimeStampOfLastAppliedOp() Deprecated. Since 2.0.0. Will be removed in 3.0.0.
long	refreshAgeOfLastAppliedOp() Refreshing the age makes sure the value returned is the actual one and not the one set a replication time
long	setAgeOfLastAppliedOp(long timestamp) Set the age of the last applied operation

Methods inherited from class java.lang.Object

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

Field Detail

lastTimestampForAge

private long lastTimestampForAge

startTimestamp

private long startTimestamp

mss

private final MetricsReplicationSinkSource mss

Constructor Detail

MetricsSink

public MetricsSink()

Method Detail

setAgeOfLastAppliedOp

public long setAgeOfLastAppliedOp(long timestamp)

Set the age of the last applied operation

Parameters:

timestamp - The timestamp of the last operation applied.

Returns:

the age that was set

refreshAgeOfLastAppliedOp

public long refreshAgeOfLastAppliedOp()

Refreshing the age makes sure the value returned is the actual one and not the one set a replication time

Returns:

refreshed age

applyBatch

public void applyBatch(long batchSize)

Convience method to change metrics when a batch of operations are applied.

Parameters:

batchSize -

applyBatch

public void applyBatch(long batchSize,
                       long hfileSize)

Convience method to change metrics when a batch of operations are applied.

Parameters:

batchSize - total number of mutations that are applied/replicated

hfileSize - total number of hfiles that are applied/replicated

getAgeOfLastAppliedOp

public long getAgeOfLastAppliedOp()

Get the Age of Last Applied Op

Returns:

ageOfLastAppliedOp

getTimeStampOfLastAppliedOp

@Deprecated
public long getTimeStampOfLastAppliedOp()

Deprecated. Since 2.0.0. Will be removed in 3.0.0.

Get the TimeStampOfLastAppliedOp. If no replication Op applied yet, the value is the timestamp at which hbase instance starts

Returns:

timeStampsOfLastAppliedOp;

See Also:

getTimestampOfLastAppliedOp()

getTimestampOfLastAppliedOp

public long getTimestampOfLastAppliedOp()

Get the TimestampOfLastAppliedOp. If no replication Op applied yet, the value is the timestamp at which hbase instance starts

Returns:

timeStampsOfLastAppliedOp;

getStartTimestamp

public long getStartTimestamp()

Gets the time stamp from when the Sink was initialized.

Returns:

startTimestamp

getAppliedOps

public long getAppliedOps()

Gets the total number of OPs delivered to this sink.

Returns:

totalAplliedOps