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

Constructor Detail

• HTableMultiplexer.FlushWorker

  public HTableMultiplexer.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

  long getNextDelay(int retryCount)

• getRetryInQueue

  AtomicInteger getRetryInQueue()

• getMaxRetryInQueue

  int getMaxRetryInQueue()

• getTotalFailedPutCount

  AtomicLong getTotalFailedPutCount()

• getMultiplexer

  HTableMultiplexer getMultiplexer()

• getExecutor

  ScheduledExecutorService getExecutor()

• run

  public void run()

  Specified by:

  run in interface Runnable