public class MetricsReplicationGlobalSourceSource extends Object implements MetricsReplicationSourceSource
Modifier and Type | Field and Description |
---|---|
private org.apache.hadoop.metrics2.lib.MutableGaugeLong |
ageOfLastShippedOpGauge |
private org.apache.hadoop.metrics2.lib.MutableCounterLong |
completedRecoveryQueue |
private org.apache.hadoop.metrics2.lib.MutableCounterLong |
completedWAL |
private org.apache.hadoop.metrics2.lib.MutableCounterLong |
logEditsFilteredCounter |
private org.apache.hadoop.metrics2.lib.MutableCounterLong |
logReadInBytesCounter |
private org.apache.hadoop.metrics2.lib.MutableCounterLong |
logReadInEditsCounter |
private org.apache.hadoop.metrics2.lib.MutableCounterLong |
repeatedFileBytes |
private org.apache.hadoop.metrics2.lib.MutableCounterLong |
restartWALReading |
private MetricsReplicationSourceImpl |
rms |
private org.apache.hadoop.metrics2.lib.MutableCounterLong |
shippedBatchesCounter |
private org.apache.hadoop.metrics2.lib.MutableCounterLong |
shippedKBsCounter |
private org.apache.hadoop.metrics2.lib.MutableCounterLong |
shippedOpsCounter |
private org.apache.hadoop.metrics2.lib.MutableGaugeLong |
sizeOfLogQueueGauge |
private org.apache.hadoop.metrics2.lib.MutableCounterLong |
uncleanlyClosedSkippedBytes |
private org.apache.hadoop.metrics2.lib.MutableCounterLong |
uncleanlyClosedWAL |
private org.apache.hadoop.metrics2.lib.MutableCounterLong |
unknownFileLengthForClosedWAL |
SOURCE_AGE_OF_LAST_SHIPPED_OP, SOURCE_CLOSED_LOGS_WITH_UNKNOWN_LENGTH, SOURCE_COMPLETED_LOGS, SOURCE_COMPLETED_RECOVERY_QUEUES, SOURCE_LOG_EDITS_FILTERED, SOURCE_LOG_READ_IN_BYTES, SOURCE_LOG_READ_IN_EDITS, SOURCE_REPEATED_LOG_FILE_BYTES, SOURCE_RESTARTED_LOG_READING, SOURCE_SHIPPED_BATCHES, SOURCE_SHIPPED_KBS, SOURCE_SHIPPED_OPS, SOURCE_SIZE_OF_LOG_QUEUE, SOURCE_UNCLEANLY_CLOSED_IGNORED_IN_BYTES, SOURCE_UNCLEANLY_CLOSED_LOGS
Constructor and Description |
---|
MetricsReplicationGlobalSourceSource(MetricsReplicationSourceImpl rms) |
Modifier and Type | Method and Description |
---|---|
void |
clear() |
void |
decrSizeOfLogQueue(int size) |
long |
getLastShippedAge() |
void |
incrBatchesShipped(int batches) |
void |
incrBytesSkippedInUncleanlyClosedWALs(long bytes) |
void |
incrCompletedRecoveryQueue() |
void |
incrCompletedWAL() |
void |
incrLogEditsFiltered(long size) |
void |
incrLogReadInBytes(long size) |
void |
incrLogReadInEdits(long size) |
void |
incrOpsShipped(long ops) |
void |
incrRepeatedFileBytes(long bytes) |
void |
incrRestartedWALReading() |
void |
incrShippedKBs(long size) |
void |
incrSizeOfLogQueue(int size) |
void |
incrUncleanlyClosedWALs() |
void |
incrUnknownFileLengthForClosedWAL() |
void |
setLastShippedAge(long age) |
void |
setSizeOfLogQueue(int size) |
private final MetricsReplicationSourceImpl rms
private final org.apache.hadoop.metrics2.lib.MutableGaugeLong ageOfLastShippedOpGauge
private final org.apache.hadoop.metrics2.lib.MutableGaugeLong sizeOfLogQueueGauge
private final org.apache.hadoop.metrics2.lib.MutableCounterLong logReadInEditsCounter
private final org.apache.hadoop.metrics2.lib.MutableCounterLong logEditsFilteredCounter
private final org.apache.hadoop.metrics2.lib.MutableCounterLong shippedBatchesCounter
private final org.apache.hadoop.metrics2.lib.MutableCounterLong shippedOpsCounter
private final org.apache.hadoop.metrics2.lib.MutableCounterLong shippedKBsCounter
private final org.apache.hadoop.metrics2.lib.MutableCounterLong logReadInBytesCounter
private final org.apache.hadoop.metrics2.lib.MutableCounterLong unknownFileLengthForClosedWAL
private final org.apache.hadoop.metrics2.lib.MutableCounterLong uncleanlyClosedWAL
private final org.apache.hadoop.metrics2.lib.MutableCounterLong uncleanlyClosedSkippedBytes
private final org.apache.hadoop.metrics2.lib.MutableCounterLong restartWALReading
private final org.apache.hadoop.metrics2.lib.MutableCounterLong repeatedFileBytes
private final org.apache.hadoop.metrics2.lib.MutableCounterLong completedWAL
private final org.apache.hadoop.metrics2.lib.MutableCounterLong completedRecoveryQueue
public MetricsReplicationGlobalSourceSource(MetricsReplicationSourceImpl rms)
public void setLastShippedAge(long age)
setLastShippedAge
in interface MetricsReplicationSourceSource
public void setSizeOfLogQueue(int size)
setSizeOfLogQueue
in interface MetricsReplicationSourceSource
public void incrSizeOfLogQueue(int size)
incrSizeOfLogQueue
in interface MetricsReplicationSourceSource
public void decrSizeOfLogQueue(int size)
decrSizeOfLogQueue
in interface MetricsReplicationSourceSource
public void incrLogReadInEdits(long size)
incrLogReadInEdits
in interface MetricsReplicationSourceSource
public void incrLogEditsFiltered(long size)
incrLogEditsFiltered
in interface MetricsReplicationSourceSource
public void incrBatchesShipped(int batches)
incrBatchesShipped
in interface MetricsReplicationSourceSource
public void incrOpsShipped(long ops)
incrOpsShipped
in interface MetricsReplicationSourceSource
public void incrShippedKBs(long size)
incrShippedKBs
in interface MetricsReplicationSourceSource
public void incrLogReadInBytes(long size)
incrLogReadInBytes
in interface MetricsReplicationSourceSource
public void clear()
clear
in interface MetricsReplicationSourceSource
public long getLastShippedAge()
getLastShippedAge
in interface MetricsReplicationSourceSource
public void incrUnknownFileLengthForClosedWAL()
incrUnknownFileLengthForClosedWAL
in interface MetricsReplicationSourceSource
public void incrUncleanlyClosedWALs()
incrUncleanlyClosedWALs
in interface MetricsReplicationSourceSource
public void incrBytesSkippedInUncleanlyClosedWALs(long bytes)
incrBytesSkippedInUncleanlyClosedWALs
in interface MetricsReplicationSourceSource
public void incrRestartedWALReading()
incrRestartedWALReading
in interface MetricsReplicationSourceSource
public void incrRepeatedFileBytes(long bytes)
incrRepeatedFileBytes
in interface MetricsReplicationSourceSource
public void incrCompletedWAL()
incrCompletedWAL
in interface MetricsReplicationSourceSource
public void incrCompletedRecoveryQueue()
incrCompletedRecoveryQueue
in interface MetricsReplicationSourceSource
Copyright © 2007–2019 The Apache Software Foundation. All rights reserved.