org.apache.hadoop.hbase.client

Class HTableMultiplexer.HTableMultiplexerStatus

java.lang.Object

org.apache.hadoop.hbase.client.HTableMultiplexer.HTableMultiplexerStatus

Enclosing class:

HTableMultiplexer

@InterfaceAudience.Public
public static class HTableMultiplexer.HTableMultiplexerStatus
extends Object

HTableMultiplexerStatus keeps track of the current status of the HTableMultiplexer. report the number of buffered requests and the number of the failed (dropped) requests in total or on per region server basis.

Constructor Summary

Constructors

Constructor and Description
HTableMultiplexerStatus(Map<HRegionLocation,org.apache.hadoop.hbase.client.HTableMultiplexer.FlushWorker> serverToFlushWorkerMap)

Method Summary

Modifier and Type	Method and Description
Map<String,Long>	getAverageLatencyForEachRegionServer()
Map<String,Long>	getBufferedCounterForEachRegionServer()
Map<String,Long>	getFailedCounterForEachRegionServer()
long	getMaxLatency()
Map<String,Long>	getMaxLatencyForEachRegionServer()
long	getOverallAverageLatency()
long	getTotalBufferedCounter()
long	getTotalFailedCounter()

Methods inherited from class java.lang.Object

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

Constructor Detail

HTableMultiplexerStatus

public HTableMultiplexerStatus(Map<HRegionLocation,org.apache.hadoop.hbase.client.HTableMultiplexer.FlushWorker> serverToFlushWorkerMap)

Method Detail

getTotalBufferedCounter

public long getTotalBufferedCounter()

getTotalFailedCounter

public long getTotalFailedCounter()

getMaxLatency

public long getMaxLatency()

getOverallAverageLatency

public long getOverallAverageLatency()

getBufferedCounterForEachRegionServer

public Map<String,Long> getBufferedCounterForEachRegionServer()

getFailedCounterForEachRegionServer

public Map<String,Long> getFailedCounterForEachRegionServer()

getMaxLatencyForEachRegionServer

public Map<String,Long> getMaxLatencyForEachRegionServer()

getAverageLatencyForEachRegionServer

public Map<String,Long> getAverageLatencyForEachRegionServer()