@InterfaceAudience.Private public class MetricsSink extends Object
Modifier and Type | Field and Description |
---|---|
private long |
lastTimestampForAge |
private MetricsReplicationSinkSource |
mss |
Constructor and Description |
---|
MetricsSink() |
Modifier and Type | Method and Description |
---|---|
void |
applyBatch(long batchSize)
Convience method to change metrics when a batch of operations are applied.
|
long |
getAgeOfLastAppliedOp()
Get the Age of Last Applied Op
|
long |
getTimeStampOfLastAppliedOp()
Get the TimeStampOfLastAppliedOp.
|
long |
refreshAgeOfLastAppliedOp()
Refreshing the age makes sure the value returned is the actual one and
not the one set a replication time
|
long |
setAgeOfLastAppliedOp(long timestamp)
Set the age of the last applied operation
|
private long lastTimestampForAge
private final MetricsReplicationSinkSource mss
public long setAgeOfLastAppliedOp(long timestamp)
timestamp
- The timestamp of the last operation applied.public long refreshAgeOfLastAppliedOp()
public void applyBatch(long batchSize)
batchSize
- public long getAgeOfLastAppliedOp()
public long getTimeStampOfLastAppliedOp()
Copyright © 2007–2019 The Apache Software Foundation. All rights reserved.