Package 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

@Private
static class HTableMultiplexer.FlushWorker
extends Object
implements Runnable

Field Summary

Fields

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

Constructor Summary

Constructors

Constructor	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	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 Details

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 Details

FlushWorker

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

Method Details

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

@Private
long getNextDelay(int retryCount)

getRetryInQueue

@Private
AtomicInteger getRetryInQueue()

getMaxRetryInQueue

@Private
int getMaxRetryInQueue()

getTotalFailedPutCount

@Private
AtomicLong getTotalFailedPutCount()

getMultiplexer

@Private
HTableMultiplexer getMultiplexer()

getExecutor

@Private
ScheduledExecutorService getExecutor()

run

public void run()

Specified by:

run in interface Runnable