@InterfaceAudience.Private public class MetricsReplicationSinkSourceImpl extends Object implements MetricsReplicationSinkSource
SINK_AGE_OF_LAST_APPLIED_OP, SINK_APPLIED_BATCHES, SINK_APPLIED_HFILES, SINK_APPLIED_OPS
Constructor and Description |
---|
MetricsReplicationSinkSourceImpl(MetricsReplicationSourceImpl rms) |
Modifier and Type | Method and Description |
---|---|
long |
getLastAppliedOpAge() |
void |
incrAppliedBatches(long batches) |
void |
incrAppliedHFiles(long hfiles) |
void |
incrAppliedOps(long batchsize) |
void |
setLastAppliedOpAge(long age) |
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
public void incrAppliedHFiles(long hfiles)
incrAppliedHFiles
in interface MetricsReplicationSinkSource
Copyright © 2007–2019 Cloudera. All rights reserved.