@InterfaceAudience.Public public class ServerSideScanMetrics extends Object
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 and Description |
---|
ServerSideScanMetrics() |
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) |
private final Map<String,AtomicLong> counters
public static final String COUNT_OF_ROWS_SCANNED_KEY_METRIC_NAME
public static final String COUNT_OF_ROWS_FILTERED_KEY_METRIC_NAME
public static final String BLOCK_BYTES_SCANNED_KEY_METRIC_NAME
public final AtomicLong countOfRowsFiltered
public final AtomicLong countOfRowsScanned
public final AtomicLong countOfBlockBytesScanned
public ServerSideScanMetrics()
protected AtomicLong createCounter(String counterName)
AtomicLong
instance for the counter with counterNamepublic void setCounter(String counterName, long value)
public boolean hasCounter(String counterName)
public AtomicLong getCounter(String counterName)
AtomicLong
instance for this counter name, null if counter does not exist.public void addToCounter(String counterName, long delta)
public Map<String,Long> getMetricsMap()
public Map<String,Long> getMetricsMap(boolean reset)
reset
- whether to reset the AtomicLongs to 0.Copyright © 2007–2020 The Apache Software Foundation. All rights reserved.