public class MetricsReplicationSinkSourceImpl extends Object implements MetricsReplicationSinkSource
| Modifier and Type | Field and Description |
|---|---|
private org.apache.hadoop.metrics2.lib.MutableGaugeLong |
ageGauge |
private org.apache.hadoop.metrics2.lib.MutableCounterLong |
batchesCounter |
private org.apache.hadoop.metrics2.lib.MutableCounterLong |
opsCounter |
SINK_AGE_OF_LAST_APPLIED_OP, SINK_APPLIED_BATCHES, SINK_APPLIED_OPS| Constructor and Description |
|---|
MetricsReplicationSinkSourceImpl(MetricsReplicationSourceImpl rms) |
| Modifier and Type | Method and Description |
|---|---|
long |
getLastAppliedOpAge() |
void |
incrAppliedBatches(long batches) |
void |
incrAppliedOps(long batchsize) |
void |
setLastAppliedOpAge(long age) |
private final org.apache.hadoop.metrics2.lib.MutableGaugeLong ageGauge
private final org.apache.hadoop.metrics2.lib.MutableCounterLong batchesCounter
private final org.apache.hadoop.metrics2.lib.MutableCounterLong opsCounter
public MetricsReplicationSinkSourceImpl(MetricsReplicationSourceImpl rms)
public void setLastAppliedOpAge(long age)
setLastAppliedOpAge in interface MetricsReplicationSinkSourcepublic void incrAppliedBatches(long batches)
incrAppliedBatches in interface MetricsReplicationSinkSourcepublic void incrAppliedOps(long batchsize)
incrAppliedOps in interface MetricsReplicationSinkSourcepublic long getLastAppliedOpAge()
getLastAppliedOpAge in interface MetricsReplicationSinkSourceCopyright © 2007–2019 The Apache Software Foundation. All rights reserved.