Package org.apache.hadoop.hbase.replication.regionserver

Class MetricsReplicationSinkSourceImpl

java.lang.Object

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

All Implemented Interfaces:

MetricsReplicationSinkSource

@Private
public class MetricsReplicationSinkSourceImpl
extends Object
implements MetricsReplicationSinkSource

Field Summary

Fields

Modifier and Type	Field	Description
private final MutableHistogram	ageHist
private final MutableFastCounter	batchesCounter
private final MutableFastCounter	failedBatchesCounter
private final MutableFastCounter	hfilesCounter
private final 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, SINK_FAILED_BATCHES

Constructor Summary

Constructors

Constructor	Description
MetricsReplicationSinkSourceImpl(MetricsReplicationSourceImpl rms)

Method Summary

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

Methods inherited from class java.lang.Object

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

Field Details

ageHist

private final MutableHistogram ageHist

batchesCounter

private final MutableFastCounter batchesCounter

failedBatchesCounter

private final MutableFastCounter failedBatchesCounter

opsCounter

private final MutableFastCounter opsCounter

hfilesCounter

private final MutableFastCounter hfilesCounter

Constructor Details

MetricsReplicationSinkSourceImpl

public MetricsReplicationSinkSourceImpl(MetricsReplicationSourceImpl rms)

Method Details

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

incrFailedBatches

public void incrFailedBatches()

Specified by:

incrFailedBatches in interface MetricsReplicationSinkSource

getFailedBatches

public long getFailedBatches()

Specified by:

getFailedBatches 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