@InterfaceAudience.Private public class MetricsThriftServerSourceImpl extends ExceptionTrackingSourceImpl implements MetricsThriftServerSource
MetricsThriftServerSource
Implements BaseSource through BaseSourceImpl, following the patternexceptions, exceptionsBusy, exceptionsCallQueueTooBig, exceptionsMoved, exceptionsMultiTooLarge, exceptionsNSRE, exceptionsOOO, exceptionsSanity, exceptionsScannerReset, exceptionsUnknown
metricsAdapter, metricsContext, metricsDescription, metricsJmxContext, metricsName, metricsRegistry, registry
ACTIVE_WORKER_COUNT_KEY, BATCH_GET_KEY, BATCH_MUTATE_KEY, CALL_QUEUE_LEN_KEY, SLOW_THRIFT_CALL_KEY, THRIFT_CALL_KEY, TIME_IN_QUEUE_KEY
EXCEPTIONS_BUSY_NAME, EXCEPTIONS_CALL_QUEUE_TOO_BIG, EXCEPTIONS_CALL_QUEUE_TOO_BIG_DESC, EXCEPTIONS_DESC, EXCEPTIONS_MOVED_NAME, EXCEPTIONS_MULTI_TOO_LARGE_DESC, EXCEPTIONS_MULTI_TOO_LARGE_NAME, EXCEPTIONS_NAME, EXCEPTIONS_NSRE_NAME, EXCEPTIONS_OOO_NAME, EXCEPTIONS_SANITY_NAME, EXCEPTIONS_SCANNER_RESET_NAME, EXCEPTIONS_TYPE_DESC, EXCEPTIONS_UNKNOWN_NAME
HBASE_METRICS_SYSTEM_NAME
INFO_THRESHOLD_COUNT_DESC, INFO_THRESHOLD_COUNT_KEY, PAUSE_TIME_WITH_GC_DESC, PAUSE_TIME_WITH_GC_KEY, PAUSE_TIME_WITHOUT_GC_DESC, PAUSE_TIME_WITHOUT_GC_KEY, WARN_THRESHOLD_COUNT_DESC, WARN_THRESHOLD_COUNT_KEY
Constructor and Description |
---|
MetricsThriftServerSourceImpl(String metricsName,
String metricsDescription,
String metricsContext,
String metricsJmxContext) |
Modifier and Type | Method and Description |
---|---|
void |
decActiveWorkerCount()
Decrement number of active thrift workers.
|
void |
incActiveWorkerCount()
Increment number of active thrift workers.
|
void |
incCall(long time)
Add how long a call took
|
void |
incInfoThresholdExceeded(int count)
Increment the INFO level threshold exceeded count
|
void |
incMethodTime(String name,
long time)
Add how long a method took
|
void |
incNumRowKeysInBatchGet(int diff)
Add how many keys were in a batch get.
|
void |
incNumRowKeysInBatchMutate(int diff)
Add how many keys were in a batch mutate.
|
void |
incSlowCall(long time)
Increment how long a slow call took.
|
void |
incTimeInQueue(long time)
Add how long an operation was in the queue.
|
void |
incWarnThresholdExceeded(int count)
Increment the WARN level threshold exceeded count
|
void |
init()
Clear out the metrics and re-prepare the source.
|
void |
setCallQueueLen(int len)
Set the call queue length.
|
void |
updatePauseTimeWithGc(long t)
Update the pause time histogram where GC activity was detected.
|
void |
updatePauseTimeWithoutGc(long t)
Update the pause time histogram where GC activity was not detected.
|
callQueueTooBigException, exception, failedSanityException, movedRegionException, multiActionTooLargeException, notServingRegionException, outOfOrderException, scannerResetException, tooBusyException, unknownScannerException
decGauge, getMetricRegistryInfo, getMetrics, getMetricsContext, getMetricsDescription, getMetricsJmxContext, getMetricsName, getMetricsRegistry, incCounters, incGauge, removeMetric, setGauge, updateHistogram
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
callQueueTooBigException, exception, failedSanityException, movedRegionException, multiActionTooLargeException, notServingRegionException, outOfOrderException, scannerResetException, tooBusyException, unknownScannerException
decGauge, getMetricRegistryInfo, getMetricsContext, getMetricsDescription, getMetricsJmxContext, getMetricsName, incCounters, incGauge, removeMetric, setGauge, updateHistogram
public void init()
BaseSource
init
in interface BaseSource
init
in class ExceptionTrackingSourceImpl
public void incTimeInQueue(long time)
MetricsThriftServerSource
incTimeInQueue
in interface MetricsThriftServerSource
public void setCallQueueLen(int len)
MetricsThriftServerSource
setCallQueueLen
in interface MetricsThriftServerSource
len
- Timepublic void incNumRowKeysInBatchGet(int diff)
MetricsThriftServerSource
incNumRowKeysInBatchGet
in interface MetricsThriftServerSource
diff
- Num Keyspublic void incNumRowKeysInBatchMutate(int diff)
MetricsThriftServerSource
incNumRowKeysInBatchMutate
in interface MetricsThriftServerSource
diff
- Num Keyspublic void incMethodTime(String name, long time)
MetricsThriftServerSource
incMethodTime
in interface MetricsThriftServerSource
name
- Method nametime
- Timepublic void incCall(long time)
MetricsThriftServerSource
incCall
in interface MetricsThriftServerSource
time
- Timepublic void incSlowCall(long time)
MetricsThriftServerSource
incSlowCall
in interface MetricsThriftServerSource
time
- Timepublic void incActiveWorkerCount()
MetricsThriftServerSource
incActiveWorkerCount
in interface MetricsThriftServerSource
public void decActiveWorkerCount()
MetricsThriftServerSource
decActiveWorkerCount
in interface MetricsThriftServerSource
public void incInfoThresholdExceeded(int count)
JvmPauseMonitorSource
incInfoThresholdExceeded
in interface JvmPauseMonitorSource
count
- the countpublic void incWarnThresholdExceeded(int count)
JvmPauseMonitorSource
incWarnThresholdExceeded
in interface JvmPauseMonitorSource
count
- the countpublic void updatePauseTimeWithGc(long t)
JvmPauseMonitorSource
updatePauseTimeWithGc
in interface JvmPauseMonitorSource
t
- time it tookpublic void updatePauseTimeWithoutGc(long t)
JvmPauseMonitorSource
updatePauseTimeWithoutGc
in interface JvmPauseMonitorSource
t
- time it tookCopyright © 2007–2019 The Apache Software Foundation. All rights reserved.