org.apache.hadoop.hbase.replication.regionserver

Class MetricsReplicationSinkSourceImpl

java.lang.Object

org.apache.hadoop.hbase.replication.regionserver.MetricsReplicationSinkSourceImpl

All Implemented Interfaces:

MetricsReplicationSinkSource

@InterfaceAudience.Private
public class MetricsReplicationSinkSourceImpl
extends Object
implements MetricsReplicationSinkSource

Field Summary

Fields

Modifier and Type	Field and Description
private MutableHistogram	ageHist
private MutableFastCounter	batchesCounter
private MutableFastCounter	hfilesCounter
private MutableFastCounter	opsCounter

Fields inherited from interface org.apache.hadoop.hbase.replication.regionserver.MetricsReplicationSinkSource

SINK_AGE_OF_LAST_APPLIED_OP, SINK_APPLIED_BATCHES, SINK_APPLIED_HFILES, SINK_APPLIED_OPS

Constructor Summary

Constructors

Constructor and Description
MetricsReplicationSinkSourceImpl(MetricsReplicationSourceImpl rms)

Method Summary

Modifier and Type	Method and Description
long	getLastAppliedOpAge()
long	getSinkAppliedOps()
void	incrAppliedBatches(long batches)
void	incrAppliedHFiles(long hfiles)
void	incrAppliedOps(long batchsize)
void	setLastAppliedOpAge(long age)

Methods inherited from class java.lang.Object

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

Field Detail

ageHist

private final MutableHistogram ageHist

batchesCounter

private final MutableFastCounter batchesCounter

opsCounter

private final MutableFastCounter opsCounter

hfilesCounter

private final MutableFastCounter hfilesCounter

Constructor Detail

MetricsReplicationSinkSourceImpl

public MetricsReplicationSinkSourceImpl(MetricsReplicationSourceImpl rms)

Method Detail

setLastAppliedOpAge

public void setLastAppliedOpAge(long age)

Specified by:

setLastAppliedOpAge in interface MetricsReplicationSinkSource

incrAppliedBatches

public void incrAppliedBatches(long batches)

Specified by:

incrAppliedBatches in interface MetricsReplicationSinkSource

incrAppliedOps

public void incrAppliedOps(long batchsize)

Specified by:

incrAppliedOps in interface MetricsReplicationSinkSource

getLastAppliedOpAge

public long getLastAppliedOpAge()

Specified by:

getLastAppliedOpAge in interface MetricsReplicationSinkSource

incrAppliedHFiles

public void incrAppliedHFiles(long hfiles)

Specified by:

incrAppliedHFiles in interface MetricsReplicationSinkSource

getSinkAppliedOps

public long getSinkAppliedOps()

Specified by:

getSinkAppliedOps in interface MetricsReplicationSinkSource