Package org.apache.hadoop.hdfs.client.impl.metrics

Class BlockReaderLocalMetrics

java.lang.Object

org.apache.hadoop.hdfs.client.impl.metrics.BlockReaderLocalMetrics

@Private
@Metrics(name="HdfsShortCircuitReads",
         about="Block Reader Local\'s Short Circuit Read latency",
         context="dfs")
public class BlockReaderLocalMetrics
extends Object

This class maintains a metric of rolling average latency for short circuit reads.

Constructor Summary

Constructors

Constructor	Description
BlockReaderLocalMetrics()

Method Summary

Modifier and Type	Method	Description
void	addShortCircuitReadLatency(long latency)	Adds short circuit read elapsed time.
void	collectThreadLocalStates()	Collects states maintained in ThreadLocal, if any.
static BlockReaderLocalMetrics	create()
org.apache.hadoop.metrics2.lib.MutableRollingAverages	getShortCircuitReadRollingAverages()	Get the MutableRollingAverage metric for testing only.

Methods inherited from class java.lang.Object

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

Constructor Details

BlockReaderLocalMetrics

public BlockReaderLocalMetrics()

Method Details

create

public static BlockReaderLocalMetrics create()

addShortCircuitReadLatency

public void addShortCircuitReadLatency(long latency)

Adds short circuit read elapsed time.

collectThreadLocalStates

public void collectThreadLocalStates()

Collects states maintained in ThreadLocal, if any.

getShortCircuitReadRollingAverages

@VisibleForTesting
public org.apache.hadoop.metrics2.lib.MutableRollingAverages getShortCircuitReadRollingAverages()

Get the MutableRollingAverage metric for testing only.

Returns: