org.apache.hadoop.hbase.client

Class HTableMultiplexer.FlushWorker

java.lang.Object

org.apache.hadoop.hbase.client.HTableMultiplexer.FlushWorker

All Implemented Interfaces:

Runnable

Enclosing class:

HTableMultiplexer

@InterfaceAudience.Private
static class HTableMultiplexer.FlushWorker
extends Object
implements Runnable

Field Summary

Fields

Modifier and Type	Field and Description
private HRegionLocation	addr
private AsyncProcess	ap
private HTableMultiplexer.AtomicAverageCounter	averageLatency
private AtomicInteger	currentProcessingCount
private ScheduledExecutorService	executor
private AtomicLong	maxLatency
private int	maxRetryInQueue
private HTableMultiplexer	multiplexer
private int	operationTimeout
private ExecutorService	pool
private List<HTableMultiplexer.PutStatus>	processingList
private LinkedBlockingQueue<HTableMultiplexer.PutStatus>	queue
private AtomicInteger	retryInQueue
private AtomicLong	totalFailedPutCount
private int	writeRpcTimeout

Constructor Summary

Constructors

Constructor and Description
FlushWorker(org.apache.hadoop.conf.Configuration conf, ClusterConnection conn, HRegionLocation addr, HTableMultiplexer htableMultiplexer, int perRegionServerBufferQueueSize, ExecutorService pool, ScheduledExecutorService executor)

Method Summary

Modifier and Type	Method and Description
HTableMultiplexer.AtomicAverageCounter	getAverageLatencyCounter()
(package private) ScheduledExecutorService	getExecutor()
long	getMaxLatency()
(package private) int	getMaxRetryInQueue()
(package private) HTableMultiplexer	getMultiplexer()
(package private) long	getNextDelay(int retryCount)
protected LinkedBlockingQueue<HTableMultiplexer.PutStatus>	getQueue()
(package private) AtomicInteger	getRetryInQueue()
long	getTotalBufferedCount()
long	getTotalFailedCount()
(package private) AtomicLong	getTotalFailedPutCount()
(package private) boolean	resubmitFailedPut(HTableMultiplexer.PutStatus ps, HRegionLocation oldLoc)
void	run()

Methods inherited from class java.lang.Object

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

Field Detail

addr

private final HRegionLocation addr

queue

private final LinkedBlockingQueue<HTableMultiplexer.PutStatus> queue

multiplexer

private final HTableMultiplexer multiplexer

totalFailedPutCount

private final AtomicLong totalFailedPutCount

currentProcessingCount

private final AtomicInteger currentProcessingCount

averageLatency

private final HTableMultiplexer.AtomicAverageCounter averageLatency

maxLatency

private final AtomicLong maxLatency

ap

private final AsyncProcess ap

processingList

private final List<HTableMultiplexer.PutStatus> processingList

executor

private final ScheduledExecutorService executor

maxRetryInQueue

private final int maxRetryInQueue

retryInQueue

private final AtomicInteger retryInQueue

writeRpcTimeout

private final int writeRpcTimeout

operationTimeout

private final int operationTimeout

pool

private final ExecutorService pool

Constructor Detail

FlushWorker

public FlushWorker(org.apache.hadoop.conf.Configuration conf,
                   ClusterConnection conn,
                   HRegionLocation addr,
                   HTableMultiplexer htableMultiplexer,
                   int perRegionServerBufferQueueSize,
                   ExecutorService pool,
                   ScheduledExecutorService executor)

Method Detail

getQueue

protected LinkedBlockingQueue<HTableMultiplexer.PutStatus> getQueue()

getTotalFailedCount

public long getTotalFailedCount()

getTotalBufferedCount

public long getTotalBufferedCount()

getAverageLatencyCounter

public HTableMultiplexer.AtomicAverageCounter getAverageLatencyCounter()

getMaxLatency

public long getMaxLatency()

resubmitFailedPut

boolean resubmitFailedPut(HTableMultiplexer.PutStatus ps,
                          HRegionLocation oldLoc)
                   throws IOException

Throws:

IOException

getNextDelay

@InterfaceAudience.Private
long getNextDelay(int retryCount)

getRetryInQueue

@InterfaceAudience.Private
AtomicInteger getRetryInQueue()

getMaxRetryInQueue

@InterfaceAudience.Private
int getMaxRetryInQueue()

getTotalFailedPutCount

@InterfaceAudience.Private
AtomicLong getTotalFailedPutCount()

getMultiplexer

@InterfaceAudience.Private
HTableMultiplexer getMultiplexer()

getExecutor

@InterfaceAudience.Private
ScheduledExecutorService getExecutor()

run

public void run()

Specified by:

run in interface Runnable