org.apache.hadoop.hbase.client.metrics

Class ServerSideScanMetrics

java.lang.Object

org.apache.hadoop.hbase.client.metrics.ServerSideScanMetrics

Direct Known Subclasses:

ScanMetrics

@InterfaceAudience.Public
public class ServerSideScanMetrics
extends Object

Provides server side metrics related to scan operations.

Field Summary

Fields

Modifier and Type	Field and Description
static String	BLOCK_BYTES_SCANNED_KEY_METRIC_NAME
static String	COUNT_OF_ROWS_FILTERED_KEY_METRIC_NAME
static String	COUNT_OF_ROWS_SCANNED_KEY_METRIC_NAME
private Map<String,AtomicLong>	counters Hash to hold the String -> Atomic Long mappings for each metric
AtomicLong	countOfBlockBytesScanned
AtomicLong	countOfRowsFiltered number of rows filtered during scan RPC
AtomicLong	countOfRowsScanned number of rows scanned during scan RPC.

Constructor Summary

Constructors

Constructor and Description
ServerSideScanMetrics()

Method Summary

Modifier and Type	Method and Description
void	addToCounter(String counterName, long delta)
protected AtomicLong	createCounter(String counterName) Create a new counter with the specified name
AtomicLong	getCounter(String counterName) Returns AtomicLong instance for this counter name, null if counter does not exist.
Map<String,Long>	getMetricsMap() Get all of the values since the last time this function was called.
Map<String,Long>	getMetricsMap(boolean reset) Get all of the values.
boolean	hasCounter(String counterName) Returns true if a counter exists with the counterName
void	setCounter(String counterName, long value)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

counters

private final Map<String,AtomicLong> counters

Hash to hold the String -> Atomic Long mappings for each metric

COUNT_OF_ROWS_SCANNED_KEY_METRIC_NAME

public static final String COUNT_OF_ROWS_SCANNED_KEY_METRIC_NAME

See Also:

Constant Field Values

COUNT_OF_ROWS_FILTERED_KEY_METRIC_NAME

public static final String COUNT_OF_ROWS_FILTERED_KEY_METRIC_NAME

See Also:

Constant Field Values

BLOCK_BYTES_SCANNED_KEY_METRIC_NAME

public static final String BLOCK_BYTES_SCANNED_KEY_METRIC_NAME

See Also:

Constant Field Values

countOfRowsFiltered

public final AtomicLong countOfRowsFiltered

number of rows filtered during scan RPC

countOfRowsScanned

public final AtomicLong countOfRowsScanned

number of rows scanned during scan RPC. Not every row scanned will be returned to the client since rows may be filtered.

countOfBlockBytesScanned

public final AtomicLong countOfBlockBytesScanned

Constructor Detail

ServerSideScanMetrics

public ServerSideScanMetrics()

Method Detail

createCounter

protected AtomicLong createCounter(String counterName)

Create a new counter with the specified name

Returns:

AtomicLong instance for the counter with counterName

setCounter

public void setCounter(String counterName,
                       long value)

hasCounter

public boolean hasCounter(String counterName)

Returns true if a counter exists with the counterName

getCounter

public AtomicLong getCounter(String counterName)

Returns AtomicLong instance for this counter name, null if counter does not exist.

addToCounter

public void addToCounter(String counterName,
                         long delta)

getMetricsMap

public Map<String,Long> getMetricsMap()

Get all of the values since the last time this function was called. Calling this function will reset all AtomicLongs in the instance back to 0.

Returns:

A Map of String -> Long for metrics

getMetricsMap

public Map<String,Long> getMetricsMap(boolean reset)

Get all of the values. If reset is true, we will reset the all AtomicLongs back to 0.

Parameters:

reset - whether to reset the AtomicLongs to 0.

Returns:

A Map of String -> Long for metrics