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 MetricsReplicationSinkSource
public void incrAppliedBatches(long batches)
incrAppliedBatches
in interface MetricsReplicationSinkSource
public void incrAppliedOps(long batchsize)
incrAppliedOps
in interface MetricsReplicationSinkSource
public long getLastAppliedOpAge()
getLastAppliedOpAge
in interface MetricsReplicationSinkSource
Copyright © 2007–2019 The Apache Software Foundation. All rights reserved.