MetricsReplicationSourceSourceImpl (Apache HBase 2.5.0 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 MutableFastCounter`	`failedBatchesCounter`
`private String`	`failedBatchesKey`
`private String`	`id`
`private String`	`keyPrefix`
`private String`	`logEditsFilteredKey`
`private MutableFastCounter`	`logReadInBytesCounter`
`private String`	`logReadInBytesKey`
`private MutableFastCounter`	`logReadInEditsCounter`
`private String`	`logReadInEditsKey`
`private org.apache.hadoop.metrics2.lib.MutableGaugeLong`	`oldestWalAge`
`private String`	`oldestWalAgeKey`
`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 org.apache.hadoop.metrics2.lib.MutableGaugeInt`	`sourceInitializing`
`private String`	`sourceInitializingKey`
`private String`	`uncleanlyClosedKey`
`private MutableFastCounter`	`uncleanlyClosedSkippedBytes`
`private MutableFastCounter`	`uncleanlyClosedWAL`
`private String`	`uncleanlySkippedBytesKey`
`private MutableFastCounter`	`unknownFileLengthForClosedWAL`
`private String`	`unknownFileLengthKey`
`private MutableFastCounter`	`walEditsFilteredCounter`

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)`
`void`	`decrSourceInitializing()`
`long`	`getEditsFiltered()`
`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.
`long`	`getOldestWalAge()`
`long`	`getShippedOps()`
`int`	`getSizeOfLogQueue()`
`int`	`getSourceInitializing()`
`long`	`getUncleanlyClosedWALs()`
`long`	`getWALEditsRead()`
`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`	`incrFailedBatches()`
`void`	`incrFailedRecoveryQueue()`
`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`	`incrSourceInitializing()`
`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`	`setOldestWalAge(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
```
  - failedBatchesKey
```
private final String failedBatchesKey
```
  - 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
```
  - oldestWalAgeKey
```
private final String oldestWalAgeKey
```
  - sourceInitializingKey
```
private final String sourceInitializingKey
```
  - ageOfLastShippedOpHist
```
private final MutableHistogram ageOfLastShippedOpHist
```
  - sizeOfLogQueueGauge
```
private final org.apache.hadoop.metrics2.lib.MutableGaugeLong sizeOfLogQueueGauge
```
  - logReadInEditsCounter
```
private final MutableFastCounter logReadInEditsCounter
```
  - walEditsFilteredCounter
```
private final MutableFastCounter walEditsFilteredCounter
```
  - shippedBatchesCounter
```
private final MutableFastCounter shippedBatchesCounter
```
  - failedBatchesCounter
```
private final MutableFastCounter failedBatchesCounter
```
  - 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
```
  - oldestWalAge
```
private final org.apache.hadoop.metrics2.lib.MutableGaugeLong oldestWalAge
```
  - sourceInitializing
```
private final org.apache.hadoop.metrics2.lib.MutableGaugeInt sourceInitializing
```
- 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
  - incrFailedBatches
```
public void incrFailedBatches()
```
    Specified by:
    
    incrFailedBatches 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
  - getUncleanlyClosedWALs
```
public long getUncleanlyClosedWALs()
```
    Specified by:
    
    getUncleanlyClosedWALs 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
  - incrFailedRecoveryQueue
```
public void incrFailedRecoveryQueue()
```
    Specified by:
    
    incrFailedRecoveryQueue in interface MetricsReplicationSourceSource
  - setOldestWalAge
```
public void setOldestWalAge(long age)
```
    Specified by:
    
    setOldestWalAge in interface MetricsReplicationSourceSource
  - getOldestWalAge
```
public long getOldestWalAge()
```
    Specified by:
    
    getOldestWalAge in interface MetricsReplicationSourceSource
  - incrSourceInitializing
```
public void incrSourceInitializing()
```
    Specified by:
    
    incrSourceInitializing in interface MetricsReplicationSourceSource
  - getSourceInitializing
```
public int getSourceInitializing()
```
    Specified by:
    
    getSourceInitializing in interface MetricsReplicationSourceSource
  - decrSourceInitializing
```
public void decrSourceInitializing()
```
    Specified by:
    
    decrSourceInitializing 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
  - getWALEditsRead
```
public long getWALEditsRead()
```
    Specified by:
    
    getWALEditsRead in interface MetricsReplicationSourceSource
  - getShippedOps
```
public long getShippedOps()
```
    Specified by:
    
    getShippedOps in interface MetricsReplicationSourceSource
  - getEditsFiltered
```
public long getEditsFiltered()
```
    Specified by:
    
    getEditsFiltered in interface MetricsReplicationSourceSource

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

failedBatchesKey

keyPrefix

shippedKBsKey

shippedBytesKey

logReadInBytesKey

shippedHFilesKey

sizeOfHFileRefsQueueKey

oldestWalAgeKey

sourceInitializingKey

ageOfLastShippedOpHist

sizeOfLogQueueGauge

logReadInEditsCounter

walEditsFilteredCounter

shippedBatchesCounter

failedBatchesCounter

shippedOpsCounter

shippedKBsCounter

shippedBytesCounter

logReadInBytesCounter

shippedHFilesCounter

sizeOfHFileRefsQueueGauge

unknownFileLengthKey

uncleanlyClosedKey

uncleanlySkippedBytesKey

restartedKey

repeatedBytesKey

completedLogsKey

completedRecoveryKey

unknownFileLengthForClosedWAL

uncleanlyClosedWAL

uncleanlyClosedSkippedBytes

restartWALReading

repeatedFileBytes

completedWAL

completedRecoveryQueue

oldestWalAge

sourceInitializing

Constructor Detail

MetricsReplicationSourceSourceImpl

Method Detail

setLastShippedAge

incrSizeOfLogQueue

decrSizeOfLogQueue

incrLogReadInEdits

incrLogEditsFiltered

incrBatchesShipped

incrFailedBatches

incrOpsShipped

incrShippedBytes

incrLogReadInBytes

clear

getLastShippedAge

incrHFilesShipped

incrSizeOfHFileRefsQueue

decrSizeOfHFileRefsQueue

getSizeOfLogQueue

incrUnknownFileLengthForClosedWAL

incrUncleanlyClosedWALs

getUncleanlyClosedWALs

incrBytesSkippedInUncleanlyClosedWALs

incrRestartedWALReading

incrRepeatedFileBytes

incrCompletedWAL