@InterfaceAudience.Private public class MetricsReplicationSinkSourceImpl extends Object implements MetricsReplicationSinkSource
Modifier and Type | Field and Description |
---|---|
private MutableHistogram |
ageHist |
private MutableFastCounter |
batchesCounter |
private MutableFastCounter |
failedBatchesCounter |
private MutableFastCounter |
hfilesCounter |
private MutableFastCounter |
opsCounter |
SINK_AGE_OF_LAST_APPLIED_OP, SINK_APPLIED_BATCHES, SINK_APPLIED_HFILES, SINK_APPLIED_OPS, SINK_FAILED_BATCHES
Constructor and Description |
---|
MetricsReplicationSinkSourceImpl(MetricsReplicationSourceImpl rms) |
Modifier and Type | Method and 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) |
private final MutableHistogram ageHist
private final MutableFastCounter batchesCounter
private final MutableFastCounter failedBatchesCounter
private final MutableFastCounter opsCounter
private final MutableFastCounter hfilesCounter
public MetricsReplicationSinkSourceImpl(MetricsReplicationSourceImpl rms)
public void setLastAppliedOpAge(long age)
setLastAppliedOpAge
in interface MetricsReplicationSinkSource
public void incrAppliedBatches(long batches)
incrAppliedBatches
in interface MetricsReplicationSinkSource
public void incrAppliedOps(long batchsize)
incrAppliedOps
in interface MetricsReplicationSinkSource
public void incrFailedBatches()
incrFailedBatches
in interface MetricsReplicationSinkSource
public long getFailedBatches()
getFailedBatches
in interface MetricsReplicationSinkSource
public long getLastAppliedOpAge()
getLastAppliedOpAge
in interface MetricsReplicationSinkSource
public void incrAppliedHFiles(long hfiles)
incrAppliedHFiles
in interface MetricsReplicationSinkSource
public long getSinkAppliedOps()
getSinkAppliedOps
in interface MetricsReplicationSinkSource
Copyright © 2007–2020 The Apache Software Foundation. All rights reserved.