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.

Field Summary

Fields

Modifier and Type	Field and Description
private long	maxLatency
private long	overallAverageLatency
private Map<String,Long>	serverToAverageLatencyMap
private Map<String,Long>	serverToBufferedCounterMap
private Map<String,Long>	serverToFailedCounterMap
private Map<String,Long>	serverToMaxLatencyMap
private long	totalBufferedPutCounter
private long	totalFailedPutCounter

Constructor Summary

Constructors

Constructor and Description
HTableMultiplexerStatus(Map<HRegionLocation,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()
private void	initialize(Map<HRegionLocation,HTableMultiplexer.FlushWorker> serverToFlushWorkerMap)

Methods inherited from class java.lang.Object

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

Field Detail

totalFailedPutCounter

private long totalFailedPutCounter

totalBufferedPutCounter

private long totalBufferedPutCounter

maxLatency

private long maxLatency

overallAverageLatency

private long overallAverageLatency

serverToFailedCounterMap

private Map<String,Long> serverToFailedCounterMap

serverToBufferedCounterMap

private Map<String,Long> serverToBufferedCounterMap

serverToAverageLatencyMap

private Map<String,Long> serverToAverageLatencyMap

serverToMaxLatencyMap

private Map<String,Long> serverToMaxLatencyMap

Constructor Detail

HTableMultiplexerStatus

public HTableMultiplexerStatus(Map<HRegionLocation,HTableMultiplexer.FlushWorker> serverToFlushWorkerMap)

Method Detail

initialize

private void initialize(Map<HRegionLocation,HTableMultiplexer.FlushWorker> serverToFlushWorkerMap)

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()