MetricsReplicationSourceSourceImpl (Apache HBase 2.0.6 API)

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

All Implemented Interfaces:: BaseSource, MetricsReplicationSourceSource

@InterfaceAudience.Private
public class MetricsReplicationSourceSourceImpl
extends Object
implements MetricsReplicationSourceSource

Field Summary

Fields
Modifier and Type	Field and Description
`private MutableHistogram`	`ageOfLastShippedOpHist`
`private String`	`ageOfLastShippedOpKey`
`private String`	`completedLogsKey`
`private String`	`completedRecoveryKey`
`private MutableFastCounter`	`completedRecoveryQueue`
`private MutableFastCounter`	`completedWAL`
`private String`	`id`
`private String`	`keyPrefix`
`private MutableFastCounter`	`logEditsFilteredCounter`
`private String`	`logEditsFilteredKey`
`private MutableFastCounter`	`logReadInBytesCounter`
`private String`	`logReadInBytesKey`
`private MutableFastCounter`	`logReadInEditsCounter`
`private String`	`logReadInEditsKey`
`private String`	`repeatedBytesKey`
`private MutableFastCounter`	`repeatedFileBytes`
`private String`	`restartedKey`
`private MutableFastCounter`	`restartWALReading`
`private MetricsReplicationSourceImpl`	`rms`
`private MutableFastCounter`	`shippedBatchesCounter`
`private String`	`shippedBatchesKey`
`private MutableFastCounter`	`shippedBytesCounter`
`private String`	`shippedBytesKey`
`private MutableFastCounter`	`shippedHFilesCounter`
`private String`	`shippedHFilesKey`
`private MutableFastCounter`	`shippedKBsCounter`
`private String`	`shippedKBsKey` Deprecated. since 1.3.0. Use `shippedBytesKey` instead.
`private MutableFastCounter`	`shippedOpsCounter`
`private String`	`shippedOpsKey`
`private org.apache.hadoop.metrics2.lib.MutableGaugeLong`	`sizeOfHFileRefsQueueGauge`
`private String`	`sizeOfHFileRefsQueueKey`
`private org.apache.hadoop.metrics2.lib.MutableGaugeLong`	`sizeOfLogQueueGauge`
`private String`	`sizeOfLogQueueKey`
`private String`	`uncleanlyClosedKey`
`private MutableFastCounter`	`uncleanlyClosedSkippedBytes`
`private MutableFastCounter`	`uncleanlyClosedWAL`
`private String`	`uncleanlySkippedBytesKey`
`private MutableFastCounter`	`unknownFileLengthForClosedWAL`
`private String`	`unknownFileLengthKey`

Fields inherited from interface org.apache.hadoop.hbase.metrics.BaseSource
HBASE_METRICS_SYSTEM_NAME

Constructor Summary

Constructors
Constructor and Description

MetricsReplicationSourceSourceImpl(MetricsReplicationSourceImpl rms, String id)

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

Method Summary

All Methods Instance Methods Concrete Methods
Modifier and Type	Method and Description
`void`	`clear()`
`void`	`decGauge(String gaugeName, long delta)` Subtract some amount from a gauge.
`void`	`decrSizeOfHFileRefsQueue(long size)`
`void`	`decrSizeOfLogQueue(int size)`
`long`	`getLastShippedAge()`
`String`	`getMetricsContext()` Get the metrics context.
`String`	`getMetricsDescription()` Get the description of what this source exposes.
`String`	`getMetricsJmxContext()` Get the name of the context in JMX that this source will be exposed through.
`String`	`getMetricsName()` Get the name of the metrics that are being exported by this source.
`int`	`getSizeOfLogQueue()`
`void`	`incCounters(String counterName, long delta)` Add some amount to a counter.
`void`	`incGauge(String gaugeName, long delta)` Add some amount to a gauge.
`void`	`incrBatchesShipped(int batches)`
`void`	`incrBytesSkippedInUncleanlyClosedWALs(long bytes)`
`void`	`incrCompletedRecoveryQueue()`
`void`	`incrCompletedWAL()`
`void`	`incrHFilesShipped(long hfiles)`
`void`	`incrLogEditsFiltered(long size)`
`void`	`incrLogReadInBytes(long size)`
`void`	`incrLogReadInEdits(long size)`
`void`	`incrOpsShipped(long ops)`
`void`	`incrRepeatedFileBytes(long bytes)`
`void`	`incrRestartedWALReading()`
`void`	`incrShippedBytes(long size)`
`void`	`incrSizeOfHFileRefsQueue(long size)`
`void`	`incrSizeOfLogQueue(int size)`
`void`	`incrUncleanlyClosedWALs()`
`void`	`incrUnknownFileLengthForClosedWAL()`
`void`	`init()` Clear out the metrics and re-prepare the source.
`void`	`removeMetric(String key)` Remove a metric and no longer announce it.
`void`	`setGauge(String gaugeName, long value)` Set a gauge to a specific value.
`void`	`setLastShippedAge(long age)`
`void`	`updateHistogram(String name, long value)` Add some value to a histogram.

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

Methods inherited from interface org.apache.hadoop.hbase.metrics.BaseSource
getMetricRegistryInfo

- Field Detail
  - rms
```
private final MetricsReplicationSourceImpl rms
```
  - id
```
private final String id
```
  - 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
```
  - keyPrefix
```
private String keyPrefix
```
  - shippedKBsKey
```
@Deprecated
private final String shippedKBsKey
```
    Deprecated. since 1.3.0. Use shippedBytesKey instead.
  - shippedBytesKey
```
private final String shippedBytesKey
```
  - logReadInBytesKey
```
private final String logReadInBytesKey
```
  - shippedHFilesKey
```
private final String shippedHFilesKey
```
  - sizeOfHFileRefsQueueKey
```
private final String sizeOfHFileRefsQueueKey
```
  - ageOfLastShippedOpHist
```
private final MutableHistogram ageOfLastShippedOpHist
```
  - sizeOfLogQueueGauge
```
private final org.apache.hadoop.metrics2.lib.MutableGaugeLong sizeOfLogQueueGauge
```
  - logReadInEditsCounter
```
private final MutableFastCounter logReadInEditsCounter
```
  - logEditsFilteredCounter
```
private final MutableFastCounter logEditsFilteredCounter
```
  - shippedBatchesCounter
```
private final MutableFastCounter shippedBatchesCounter
```
  - shippedOpsCounter
```
private final MutableFastCounter shippedOpsCounter
```
  - shippedKBsCounter
```
private final MutableFastCounter shippedKBsCounter
```
  - shippedBytesCounter
```
private final MutableFastCounter shippedBytesCounter
```
  - logReadInBytesCounter
```
private final MutableFastCounter logReadInBytesCounter
```
  - shippedHFilesCounter
```
private final MutableFastCounter shippedHFilesCounter
```
  - sizeOfHFileRefsQueueGauge
```
private final org.apache.hadoop.metrics2.lib.MutableGaugeLong sizeOfHFileRefsQueueGauge
```
  - 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 MutableFastCounter unknownFileLengthForClosedWAL
```
  - uncleanlyClosedWAL
```
private final MutableFastCounter uncleanlyClosedWAL
```
  - uncleanlyClosedSkippedBytes
```
private final MutableFastCounter uncleanlyClosedSkippedBytes
```
  - restartWALReading
```
private final MutableFastCounter restartWALReading
```
  - repeatedFileBytes
```
private final MutableFastCounter repeatedFileBytes
```
  - completedWAL
```
private final MutableFastCounter completedWAL
```
  - completedRecoveryQueue
```
private final MutableFastCounter completedRecoveryQueue
```
- Constructor Detail
  - MetricsReplicationSourceSourceImpl
```
public MetricsReplicationSourceSourceImpl(MetricsReplicationSourceImpl rms,
                                          String id)
```
- Method Detail
  - setLastShippedAge
```
public void setLastShippedAge(long age)
```
    Specified by:
    
    setLastShippedAge 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
  - incrShippedBytes
```
public void incrShippedBytes(long size)
```
    Specified by:
    
    incrShippedBytes 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
  - incrHFilesShipped
```
public void incrHFilesShipped(long hfiles)
```
    Specified by:
    
    incrHFilesShipped in interface MetricsReplicationSourceSource
  - incrSizeOfHFileRefsQueue
```
public void incrSizeOfHFileRefsQueue(long size)
```
    Specified by:
    
    incrSizeOfHFileRefsQueue in interface MetricsReplicationSourceSource
  - decrSizeOfHFileRefsQueue
```
public void decrSizeOfHFileRefsQueue(long size)
```
    Specified by:
    
    decrSizeOfHFileRefsQueue in interface MetricsReplicationSourceSource
  - getSizeOfLogQueue
```
public int getSizeOfLogQueue()
```
    Specified by:
    
    getSizeOfLogQueue 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
  - init
```
public void init()
```
    Description copied from interface: BaseSource
    
    Clear out the metrics and re-prepare the source.
    
    Specified by:
    
    init in interface BaseSource
  - setGauge
```
public void setGauge(String gaugeName,
                     long value)
```
    Description copied from interface: BaseSource
    
    Set a gauge to a specific value.
    
    Specified by:
    
    setGauge in interface BaseSource
    
    Parameters:
    
    gaugeName - the name of the gauge
    
    value - the value
  - incGauge
```
public void incGauge(String gaugeName,
                     long delta)
```
    Description copied from interface: BaseSource
    
    Add some amount to a gauge.
    
    Specified by:
    
    incGauge in interface BaseSource
    
    Parameters:
    
    gaugeName - the name of the gauge
    
    delta - the amount to change the gauge by.
  - decGauge
```
public void decGauge(String gaugeName,
                     long delta)
```
    Description copied from interface: BaseSource
    
    Subtract some amount from a gauge.
    
    Specified by:
    
    decGauge in interface BaseSource
    
    Parameters:
    
    gaugeName - the name of the gauge
    
    delta - the amount to change the gauge by.
  - removeMetric
```
public void removeMetric(String key)
```
    Description copied from interface: BaseSource
    
    Remove a metric and no longer announce it.
    
    Specified by:
    
    removeMetric in interface BaseSource
    
    Parameters:
    
    key - Name of the gauge to remove.
  - incCounters
```
public void incCounters(String counterName,
                        long delta)
```
    Description copied from interface: BaseSource
    
    Add some amount to a counter.
    
    Specified by:
    
    incCounters in interface BaseSource
    
    Parameters:
    
    counterName - the name of the counter
    
    delta - the amount to change the counter by.
  - updateHistogram
```
public void updateHistogram(String name,
                            long value)
```
    Description copied from interface: BaseSource
    
    Add some value to a histogram.
    
    Specified by:
    
    updateHistogram in interface BaseSource
    
    Parameters:
    
    name - the name of the histogram
    
    value - the value to add to the histogram
  - getMetricsContext
```
public String getMetricsContext()
```
    Description copied from interface: BaseSource
    
    Get the metrics context. For hadoop metrics2 system this is usually an all lowercased string. eg. regionserver, master, thriftserver
    
    Specified by:
    
    getMetricsContext in interface BaseSource
    
    Returns:
    
    The string context used to register this source to hadoop's metrics2 system.
  - getMetricsDescription
```
public String getMetricsDescription()
```
    Description copied from interface: BaseSource
    
    Get the description of what this source exposes.
    
    Specified by:
    
    getMetricsDescription in interface BaseSource
  - getMetricsJmxContext
```
public String getMetricsJmxContext()
```
    Description copied from interface: BaseSource
    
    Get the name of the context in JMX that this source will be exposed through. This is in ObjectName format. With the default context being Hadoop -> HBase
    
    Specified by:
    
    getMetricsJmxContext in interface BaseSource
  - getMetricsName
```
public String getMetricsName()
```
    Description copied from interface: BaseSource
    
    Get the name of the metrics that are being exported by this source. Eg. IPC, GC, WAL
    
    Specified by:
    
    getMetricsName in interface BaseSource

Class MetricsReplicationSourceSourceImpl

Field Summary

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

Fields inherited from interface org.apache.hadoop.hbase.metrics.BaseSource

Constructor Summary

Method Summary

Methods inherited from class java.lang.Object

Methods inherited from interface org.apache.hadoop.hbase.metrics.BaseSource

Field Detail

rms

id

sizeOfLogQueueKey

ageOfLastShippedOpKey

logReadInEditsKey

logEditsFilteredKey

shippedBatchesKey

shippedOpsKey

keyPrefix

shippedKBsKey

shippedBytesKey

logReadInBytesKey

shippedHFilesKey

sizeOfHFileRefsQueueKey

ageOfLastShippedOpHist

sizeOfLogQueueGauge

logReadInEditsCounter

logEditsFilteredCounter

shippedBatchesCounter

shippedOpsCounter

shippedKBsCounter

shippedBytesCounter

logReadInBytesCounter

shippedHFilesCounter

sizeOfHFileRefsQueueGauge

unknownFileLengthKey

uncleanlyClosedKey

uncleanlySkippedBytesKey

restartedKey

repeatedBytesKey

completedLogsKey

completedRecoveryKey

unknownFileLengthForClosedWAL

uncleanlyClosedWAL

uncleanlyClosedSkippedBytes

restartWALReading

repeatedFileBytes

completedWAL

completedRecoveryQueue

Constructor Detail

MetricsReplicationSourceSourceImpl

Method Detail

setLastShippedAge

incrSizeOfLogQueue

decrSizeOfLogQueue

incrLogReadInEdits

incrLogEditsFiltered

incrBatchesShipped

incrOpsShipped

incrShippedBytes

incrLogReadInBytes

clear

getLastShippedAge

incrHFilesShipped

incrSizeOfHFileRefsQueue

decrSizeOfHFileRefsQueue

getSizeOfLogQueue

incrUnknownFileLengthForClosedWAL

incrUncleanlyClosedWALs

incrBytesSkippedInUncleanlyClosedWALs

incrRestartedWALReading

incrRepeatedFileBytes

incrCompletedWAL

incrCompletedRecoveryQueue

init

setGauge

incGauge

decGauge

removeMetric

incCounters

updateHistogram