MetricsReplicationSourceSourceImpl (Apache HBase 1.2.12 API)

java.lang.Object
- org.apache.hadoop.hbase.replication.regionserver.MetricsReplicationSourceSourceImpl

All Implemented Interfaces:: MetricsReplicationSourceSource

public class MetricsReplicationSourceSourceImpl
extends Object
implements MetricsReplicationSourceSource

Field Summary

Fields
Modifier and Type	Field and Description
`private org.apache.hadoop.metrics2.lib.MutableGaugeLong`	`ageOfLastShippedOpGauge`
`private String`	`ageOfLastShippedOpKey`
`private String`	`completedLogsKey`
`private String`	`completedRecoveryKey`
`private org.apache.hadoop.metrics2.lib.MutableCounterLong`	`completedRecoveryQueue`
`private org.apache.hadoop.metrics2.lib.MutableCounterLong`	`completedWAL`
`private String`	`id`
`private String`	`keyPrefix`
`private org.apache.hadoop.metrics2.lib.MutableCounterLong`	`logEditsFilteredCounter`
`private String`	`logEditsFilteredKey`
`private org.apache.hadoop.metrics2.lib.MutableCounterLong`	`logReadInBytesCounter`
`private String`	`logReadInBytesKey`
`private org.apache.hadoop.metrics2.lib.MutableCounterLong`	`logReadInEditsCounter`
`private String`	`logReadInEditsKey`
`private String`	`repeatedBytesKey`
`private org.apache.hadoop.metrics2.lib.MutableCounterLong`	`repeatedFileBytes`
`private String`	`restartedKey`
`private org.apache.hadoop.metrics2.lib.MutableCounterLong`	`restartWALReading`
`private MetricsReplicationSourceImpl`	`rms`
`private org.apache.hadoop.metrics2.lib.MutableCounterLong`	`shippedBatchesCounter`
`private String`	`shippedBatchesKey`
`private org.apache.hadoop.metrics2.lib.MutableCounterLong`	`shippedKBsCounter`
`private String`	`shippedKBsKey`
`private org.apache.hadoop.metrics2.lib.MutableCounterLong`	`shippedOpsCounter`
`private String`	`shippedOpsKey`
`private org.apache.hadoop.metrics2.lib.MutableGaugeLong`	`sizeOfLogQueueGauge`
`private String`	`sizeOfLogQueueKey`
`private String`	`uncleanlyClosedKey`
`private org.apache.hadoop.metrics2.lib.MutableCounterLong`	`uncleanlyClosedSkippedBytes`
`private org.apache.hadoop.metrics2.lib.MutableCounterLong`	`uncleanlyClosedWAL`
`private String`	`uncleanlySkippedBytesKey`
`private org.apache.hadoop.metrics2.lib.MutableCounterLong`	`unknownFileLengthForClosedWAL`
`private String`	`unknownFileLengthKey`

Fields inherited from interface org.apache.hadoop.hbase.replication.regionserver.MetricsReplicationSourceSource
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 Summary

Constructors
Constructor and Description

MetricsReplicationSourceSourceImpl(MetricsReplicationSourceImpl rms, String id)

Constructors
Constructor and Description
`MetricsReplicationSourceSourceImpl(MetricsReplicationSourceImpl rms, String id)`

Method Summary

Methods
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)`

Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

rms

private final MetricsReplicationSourceImpl rms

id
```
private final String id
```

keyPrefix
```
private final String keyPrefix
```

sizeOfLogQueueKey
```
private final String sizeOfLogQueueKey
```

ageOfLastShippedOpKey

private final String ageOfLastShippedOpKey

logReadInEditsKey
```
private final String logReadInEditsKey
```

logEditsFilteredKey

private final String logEditsFilteredKey

shippedBatchesKey
```
private final String shippedBatchesKey
```

shippedOpsKey
```
private final String shippedOpsKey
```

shippedKBsKey
```
private final String shippedKBsKey
```

logReadInBytesKey
```
private final String logReadInBytesKey
```

ageOfLastShippedOpGauge

private final org.apache.hadoop.metrics2.lib.MutableGaugeLong ageOfLastShippedOpGauge

sizeOfLogQueueGauge

private final org.apache.hadoop.metrics2.lib.MutableGaugeLong sizeOfLogQueueGauge

logReadInEditsCounter

private final org.apache.hadoop.metrics2.lib.MutableCounterLong logReadInEditsCounter

logEditsFilteredCounter

private final org.apache.hadoop.metrics2.lib.MutableCounterLong logEditsFilteredCounter

shippedBatchesCounter

private final org.apache.hadoop.metrics2.lib.MutableCounterLong shippedBatchesCounter

shippedOpsCounter

private final org.apache.hadoop.metrics2.lib.MutableCounterLong shippedOpsCounter

shippedKBsCounter

private final org.apache.hadoop.metrics2.lib.MutableCounterLong shippedKBsCounter

logReadInBytesCounter

private final org.apache.hadoop.metrics2.lib.MutableCounterLong logReadInBytesCounter

unknownFileLengthKey

private final String unknownFileLengthKey

uncleanlyClosedKey

private final String uncleanlyClosedKey

uncleanlySkippedBytesKey

private final String uncleanlySkippedBytesKey

restartedKey
```
private final String restartedKey
```

repeatedBytesKey
```
private final String repeatedBytesKey
```

completedLogsKey
```
private final String completedLogsKey
```

completedRecoveryKey

private final String completedRecoveryKey

unknownFileLengthForClosedWAL

private final org.apache.hadoop.metrics2.lib.MutableCounterLong unknownFileLengthForClosedWAL

uncleanlyClosedWAL

private final org.apache.hadoop.metrics2.lib.MutableCounterLong uncleanlyClosedWAL

uncleanlyClosedSkippedBytes

private final org.apache.hadoop.metrics2.lib.MutableCounterLong uncleanlyClosedSkippedBytes

restartWALReading

private final org.apache.hadoop.metrics2.lib.MutableCounterLong restartWALReading

repeatedFileBytes

private final org.apache.hadoop.metrics2.lib.MutableCounterLong repeatedFileBytes

completedWAL

private final org.apache.hadoop.metrics2.lib.MutableCounterLong completedWAL

completedRecoveryQueue

private final org.apache.hadoop.metrics2.lib.MutableCounterLong completedRecoveryQueue

Constructor Detail

MetricsReplicationSourceSourceImpl

public MetricsReplicationSourceSourceImpl(MetricsReplicationSourceImpl rms,
                                  String id)

Method Detail
- setLastShippedAge
```
public void setLastShippedAge(long age)
```
  Specified by:
  
  setLastShippedAge in interface MetricsReplicationSourceSource
- setSizeOfLogQueue
```
public void setSizeOfLogQueue(int size)
```
  Specified by:
  
  setSizeOfLogQueue in interface MetricsReplicationSourceSource
- incrSizeOfLogQueue
```
public void incrSizeOfLogQueue(int size)
```
  Specified by:
  
  incrSizeOfLogQueue in interface MetricsReplicationSourceSource
- decrSizeOfLogQueue
```
public void decrSizeOfLogQueue(int size)
```
  Specified by:
  
  decrSizeOfLogQueue in interface MetricsReplicationSourceSource
- incrLogReadInEdits
```
public void incrLogReadInEdits(long size)
```
  Specified by:
  
  incrLogReadInEdits in interface MetricsReplicationSourceSource
- incrLogEditsFiltered
```
public void incrLogEditsFiltered(long size)
```
  Specified by:
  
  incrLogEditsFiltered in interface MetricsReplicationSourceSource
- incrBatchesShipped
```
public void incrBatchesShipped(int batches)
```
  Specified by:
  
  incrBatchesShipped in interface MetricsReplicationSourceSource
- incrOpsShipped
```
public void incrOpsShipped(long ops)
```
  Specified by:
  
  incrOpsShipped in interface MetricsReplicationSourceSource
- incrShippedKBs
```
public void incrShippedKBs(long size)
```
  Specified by:
  
  incrShippedKBs in interface MetricsReplicationSourceSource
- incrLogReadInBytes
```
public void incrLogReadInBytes(long size)
```
  Specified by:
  
  incrLogReadInBytes in interface MetricsReplicationSourceSource
- clear
```
public void clear()
```
  Specified by:
  
  clear in interface MetricsReplicationSourceSource
- getLastShippedAge
```
public long getLastShippedAge()
```
  Specified by:
  
  getLastShippedAge in interface MetricsReplicationSourceSource
- incrUnknownFileLengthForClosedWAL
```
public void incrUnknownFileLengthForClosedWAL()
```
  Specified by:
  
  incrUnknownFileLengthForClosedWAL in interface MetricsReplicationSourceSource
- incrUncleanlyClosedWALs
```
public void incrUncleanlyClosedWALs()
```
  Specified by:
  
  incrUncleanlyClosedWALs in interface MetricsReplicationSourceSource
- incrBytesSkippedInUncleanlyClosedWALs
```
public void incrBytesSkippedInUncleanlyClosedWALs(long bytes)
```
  Specified by:
  
  incrBytesSkippedInUncleanlyClosedWALs in interface MetricsReplicationSourceSource
- incrRestartedWALReading
```
public void incrRestartedWALReading()
```
  Specified by:
  
  incrRestartedWALReading in interface MetricsReplicationSourceSource
- incrRepeatedFileBytes
```
public void incrRepeatedFileBytes(long bytes)
```
  Specified by:
  
  incrRepeatedFileBytes in interface MetricsReplicationSourceSource
- incrCompletedWAL
```
public void incrCompletedWAL()
```
  Specified by:
  
  incrCompletedWAL in interface MetricsReplicationSourceSource
- incrCompletedRecoveryQueue
```
public void incrCompletedRecoveryQueue()
```
  Specified by:
  
  incrCompletedRecoveryQueue in interface MetricsReplicationSourceSource

Class MetricsReplicationSourceSourceImpl

Field Summary

Fields inherited from interface org.apache.hadoop.hbase.replication.regionserver.MetricsReplicationSourceSource

Constructor Summary

Method Summary

Methods inherited from class java.lang.Object

Field Detail

rms

id

keyPrefix

sizeOfLogQueueKey

ageOfLastShippedOpKey

logReadInEditsKey

logEditsFilteredKey

shippedBatchesKey

shippedOpsKey

shippedKBsKey

logReadInBytesKey

ageOfLastShippedOpGauge

sizeOfLogQueueGauge

logReadInEditsCounter

logEditsFilteredCounter

shippedBatchesCounter

shippedOpsCounter

shippedKBsCounter

logReadInBytesCounter

unknownFileLengthKey

uncleanlyClosedKey

uncleanlySkippedBytesKey

restartedKey

repeatedBytesKey

completedLogsKey

completedRecoveryKey

unknownFileLengthForClosedWAL

uncleanlyClosedWAL

uncleanlyClosedSkippedBytes

restartWALReading

repeatedFileBytes

completedWAL

completedRecoveryQueue

Constructor Detail

MetricsReplicationSourceSourceImpl

Method Detail

setLastShippedAge

setSizeOfLogQueue

incrSizeOfLogQueue

decrSizeOfLogQueue

incrLogReadInEdits

incrLogEditsFiltered

incrBatchesShipped

incrOpsShipped

incrShippedKBs

incrLogReadInBytes

clear

getLastShippedAge

incrUnknownFileLengthForClosedWAL

incrUncleanlyClosedWALs

incrBytesSkippedInUncleanlyClosedWALs

incrRestartedWALReading

incrRepeatedFileBytes

incrCompletedWAL

incrCompletedRecoveryQueue