Package org.apache.hadoop.hbase.thrift
Class MetricsThriftServerSourceImpl
java.lang.Object
org.apache.hadoop.hbase.metrics.BaseSourceImpl
org.apache.hadoop.hbase.metrics.ExceptionTrackingSourceImpl
org.apache.hadoop.hbase.thrift.MetricsThriftServerSourceImpl
- All Implemented Interfaces:
BaseSource
,ExceptionTrackingSource
,JvmPauseMonitorSource
,MetricsThriftServerSource
,org.apache.hadoop.metrics2.MetricsSource
@Private
public class MetricsThriftServerSourceImpl
extends ExceptionTrackingSourceImpl
implements MetricsThriftServerSource
Hadoop 2 version of
MetricsThriftServerSource
Implements
BaseSource through BaseSourceImpl, following the pattern-
Field Summary
Modifier and TypeFieldDescriptionprivate org.apache.hadoop.metrics2.lib.MutableGaugeLong
private MetricHistogram
private MetricHistogram
private org.apache.hadoop.metrics2.lib.MutableGaugeLong
private final MutableFastCounter
private final MetricHistogram
private final MetricHistogram
private MetricHistogram
private MetricHistogram
private MetricHistogram
private final MutableFastCounter
Fields inherited from class org.apache.hadoop.hbase.metrics.ExceptionTrackingSourceImpl
exceptionRequestTooBig, exceptions, exceptionsBusy, exceptionsCallDropped, exceptionsCallQueueTooBig, exceptionsCallTimedOut, exceptionsMoved, exceptionsMultiTooLarge, exceptionsNSRE, exceptionsOOO, exceptionsQuotaExceeded, exceptionsRpcThrottling, exceptionsSanity, exceptionsScannerReset, exceptionsUnknown, otherExceptions
Fields inherited from class org.apache.hadoop.hbase.metrics.BaseSourceImpl
metricsAdapter, metricsContext, metricsDescription, metricsJmxContext, metricsName, metricsRegistry, registry
Fields inherited from interface org.apache.hadoop.hbase.metrics.BaseSource
HBASE_METRICS_SYSTEM_NAME
Fields inherited from interface org.apache.hadoop.hbase.metrics.ExceptionTrackingSource
EXCEPTIONS_BUSY_NAME, EXCEPTIONS_CALL_DROPPED, EXCEPTIONS_CALL_QUEUE_TOO_BIG, EXCEPTIONS_CALL_QUEUE_TOO_BIG_DESC, EXCEPTIONS_CALL_TIMED_OUT, EXCEPTIONS_DESC, EXCEPTIONS_MOVED_NAME, EXCEPTIONS_MULTI_TOO_LARGE_DESC, EXCEPTIONS_MULTI_TOO_LARGE_NAME, EXCEPTIONS_NAME, EXCEPTIONS_NSRE_NAME, EXCEPTIONS_OOO_NAME, EXCEPTIONS_QUOTA_EXCEEDED, EXCEPTIONS_REQUEST_TOO_BIG, EXCEPTIONS_RPC_THROTTLING, EXCEPTIONS_SANITY_NAME, EXCEPTIONS_SCANNER_RESET_NAME, EXCEPTIONS_TYPE_DESC, EXCEPTIONS_UNKNOWN_NAME, OTHER_EXCEPTIONS
Fields inherited from interface org.apache.hadoop.hbase.metrics.JvmPauseMonitorSource
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
Fields inherited from interface org.apache.hadoop.hbase.thrift.MetricsThriftServerSource
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
-
Constructor Summary
ConstructorDescriptionMetricsThriftServerSourceImpl
(String metricsName, String metricsDescription, String metricsContext, String metricsJmxContext) -
Method Summary
Modifier and TypeMethodDescriptionvoid
Decrement number of active thrift workers.void
Increment number of active thrift workers.void
incCall
(long time) Add how long a call tookvoid
incInfoThresholdExceeded
(int count) Increment the INFO level threshold exceeded countvoid
incMethodTime
(String name, long time) Add how long a method tookvoid
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 countvoid
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.Methods inherited from class org.apache.hadoop.hbase.metrics.ExceptionTrackingSourceImpl
callDroppedException, callQueueTooBigException, callTimedOut, exception, failedSanityException, movedRegionException, multiActionTooLargeException, notServingRegionException, otherExceptions, outOfOrderException, quotaExceededException, requestTooBigException, rpcThrottlingException, scannerResetException, tooBusyException, unknownScannerException
Methods inherited from class org.apache.hadoop.hbase.metrics.BaseSourceImpl
decGauge, getMetrics, getMetricsContext, getMetricsDescription, getMetricsJmxContext, getMetricsName, getMetricsRegistry, incCounters, incGauge, removeMetric, setGauge, updateHistogram
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
decGauge, getMetricRegistryInfo, getMetricsContext, getMetricsDescription, getMetricsJmxContext, getMetricsName, incCounters, incGauge, removeMetric, setGauge, updateHistogram
Methods inherited from interface org.apache.hadoop.hbase.metrics.ExceptionTrackingSource
callDroppedException, callQueueTooBigException, callTimedOut, exception, failedSanityException, movedRegionException, multiActionTooLargeException, notServingRegionException, otherExceptions, outOfOrderException, quotaExceededException, requestTooBigException, rpcThrottlingException, scannerResetException, tooBusyException, unknownScannerException
-
Field Details
-
batchGetStat
-
batchMutateStat
-
queueTimeStat
-
thriftCallStat
-
thriftSlowCallStat
-
callQueueLenGauge
-
activeWorkerCountGauge
-
infoPauseThresholdExceeded
-
warnPauseThresholdExceeded
-
pausesWithGc
-
pausesWithoutGc
-
-
Constructor Details
-
MetricsThriftServerSourceImpl
public MetricsThriftServerSourceImpl(String metricsName, String metricsDescription, String metricsContext, String metricsJmxContext)
-
-
Method Details
-
init
Description copied from interface:BaseSource
Clear out the metrics and re-prepare the source.- Specified by:
init
in interfaceBaseSource
- Overrides:
init
in classExceptionTrackingSourceImpl
-
incTimeInQueue
Description copied from interface:MetricsThriftServerSource
Add how long an operation was in the queue.- Specified by:
incTimeInQueue
in interfaceMetricsThriftServerSource
-
setCallQueueLen
Description copied from interface:MetricsThriftServerSource
Set the call queue length.- Specified by:
setCallQueueLen
in interfaceMetricsThriftServerSource
- Parameters:
len
- Time
-
incNumRowKeysInBatchGet
Description copied from interface:MetricsThriftServerSource
Add how many keys were in a batch get.- Specified by:
incNumRowKeysInBatchGet
in interfaceMetricsThriftServerSource
- Parameters:
diff
- Num Keys
-
incNumRowKeysInBatchMutate
Description copied from interface:MetricsThriftServerSource
Add how many keys were in a batch mutate.- Specified by:
incNumRowKeysInBatchMutate
in interfaceMetricsThriftServerSource
- Parameters:
diff
- Num Keys
-
incMethodTime
Description copied from interface:MetricsThriftServerSource
Add how long a method took- Specified by:
incMethodTime
in interfaceMetricsThriftServerSource
- Parameters:
name
- Method nametime
- Time
-
incCall
Description copied from interface:MetricsThriftServerSource
Add how long a call took- Specified by:
incCall
in interfaceMetricsThriftServerSource
- Parameters:
time
- Time
-
incSlowCall
Description copied from interface:MetricsThriftServerSource
Increment how long a slow call took.- Specified by:
incSlowCall
in interfaceMetricsThriftServerSource
- Parameters:
time
- Time
-
incActiveWorkerCount
Description copied from interface:MetricsThriftServerSource
Increment number of active thrift workers.- Specified by:
incActiveWorkerCount
in interfaceMetricsThriftServerSource
-
decActiveWorkerCount
Description copied from interface:MetricsThriftServerSource
Decrement number of active thrift workers.- Specified by:
decActiveWorkerCount
in interfaceMetricsThriftServerSource
-
incInfoThresholdExceeded
Description copied from interface:JvmPauseMonitorSource
Increment the INFO level threshold exceeded count- Specified by:
incInfoThresholdExceeded
in interfaceJvmPauseMonitorSource
- Parameters:
count
- the count
-
incWarnThresholdExceeded
Description copied from interface:JvmPauseMonitorSource
Increment the WARN level threshold exceeded count- Specified by:
incWarnThresholdExceeded
in interfaceJvmPauseMonitorSource
- Parameters:
count
- the count
-
updatePauseTimeWithGc
Description copied from interface:JvmPauseMonitorSource
Update the pause time histogram where GC activity was detected.- Specified by:
updatePauseTimeWithGc
in interfaceJvmPauseMonitorSource
- Parameters:
t
- time it took
-
updatePauseTimeWithoutGc
Description copied from interface:JvmPauseMonitorSource
Update the pause time histogram where GC activity was not detected.- Specified by:
updatePauseTimeWithoutGc
in interfaceJvmPauseMonitorSource
- Parameters:
t
- time it took
-