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 MetricsReplicationSourceSourcepublic void setSizeOfLogQueue(int size)
setSizeOfLogQueue in interface MetricsReplicationSourceSourcepublic void incrSizeOfLogQueue(int size)
incrSizeOfLogQueue in interface MetricsReplicationSourceSourcepublic void decrSizeOfLogQueue(int size)
decrSizeOfLogQueue in interface MetricsReplicationSourceSourcepublic void incrLogReadInEdits(long size)
incrLogReadInEdits in interface MetricsReplicationSourceSourcepublic void incrLogEditsFiltered(long size)
incrLogEditsFiltered in interface MetricsReplicationSourceSourcepublic void incrBatchesShipped(int batches)
incrBatchesShipped in interface MetricsReplicationSourceSourcepublic void incrOpsShipped(long ops)
incrOpsShipped in interface MetricsReplicationSourceSourcepublic void incrShippedKBs(long size)
incrShippedKBs in interface MetricsReplicationSourceSourcepublic void incrLogReadInBytes(long size)
incrLogReadInBytes in interface MetricsReplicationSourceSourcepublic void clear()
clear in interface MetricsReplicationSourceSourcepublic long getLastShippedAge()
getLastShippedAge in interface MetricsReplicationSourceSourcepublic void incrUnknownFileLengthForClosedWAL()
incrUnknownFileLengthForClosedWAL in interface MetricsReplicationSourceSourcepublic void incrUncleanlyClosedWALs()
incrUncleanlyClosedWALs in interface MetricsReplicationSourceSourcepublic void incrBytesSkippedInUncleanlyClosedWALs(long bytes)
incrBytesSkippedInUncleanlyClosedWALs in interface MetricsReplicationSourceSourcepublic void incrRestartedWALReading()
incrRestartedWALReading in interface MetricsReplicationSourceSourcepublic void incrRepeatedFileBytes(long bytes)
incrRepeatedFileBytes in interface MetricsReplicationSourceSourcepublic void incrCompletedWAL()
incrCompletedWAL in interface MetricsReplicationSourceSourcepublic void incrCompletedRecoveryQueue()
incrCompletedRecoveryQueue in interface MetricsReplicationSourceSourceCopyright © 2007–2019 The Apache Software Foundation. All rights reserved.