org.apache.hadoop.hbase.client

类 RpcRetryingCallerWithReadReplicas.ResultBoundedCompletionService

java.lang.Object

org.apache.hadoop.hbase.client.RpcRetryingCallerWithReadReplicas.ResultBoundedCompletionService

封闭类:

RpcRetryingCallerWithReadReplicas

public class RpcRetryingCallerWithReadReplicas.ResultBoundedCompletionService
extends Object

A completion service for the RpcRetryingCallerFactory. Keeps the list of the futures, and allows to cancel them all. This means as well that it can be used for a small set of tasks only.
Implementation is not Thread safe.

构造器概要

构造器

构造器和说明
RpcRetryingCallerWithReadReplicas.ResultBoundedCompletionService(Executor executor, int maxTasks)

方法概要

方法

限定符和类型	方法和说明
void	cancelAll()
org.apache.hadoop.hbase.client.RpcRetryingCallerWithReadReplicas.ResultBoundedCompletionService.QueueingFuture	poll(long timeout, TimeUnit unit)
void	submit(org.apache.hadoop.hbase.client.RpcRetryingCallerWithReadReplicas.ReplicaRegionServerCallable task, int callTimeout)
org.apache.hadoop.hbase.client.RpcRetryingCallerWithReadReplicas.ResultBoundedCompletionService.QueueingFuture	take()

从类继承的方法 java.lang.Object

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

构造器详细资料

RpcRetryingCallerWithReadReplicas.ResultBoundedCompletionService

public RpcRetryingCallerWithReadReplicas.ResultBoundedCompletionService(Executor executor,
                                                                int maxTasks)

方法详细资料

submit

public void submit(org.apache.hadoop.hbase.client.RpcRetryingCallerWithReadReplicas.ReplicaRegionServerCallable task,
          int callTimeout)

take

public org.apache.hadoop.hbase.client.RpcRetryingCallerWithReadReplicas.ResultBoundedCompletionService.QueueingFuture take()
                                                                                                                    throws InterruptedException

抛出:

InterruptedException

poll

public org.apache.hadoop.hbase.client.RpcRetryingCallerWithReadReplicas.ResultBoundedCompletionService.QueueingFuture poll(long timeout,
                                                                                                                  TimeUnit unit)
                                                                                                                    throws InterruptedException

抛出:

InterruptedException

cancelAll

public void cancelAll()