org.apache.hadoop.hbase.client

Class ResultBoundedCompletionService<V>

java.lang.Object

org.apache.hadoop.hbase.client.ResultBoundedCompletionService<V>

@InterfaceAudience.Private
public class ResultBoundedCompletionService<V>
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.

Constructor Summary

Constructors

Constructor and Description
ResultBoundedCompletionService(RpcRetryingCallerFactory retryingCallerFactory, Executor executor, int maxTasks)

Method Summary

Modifier and Type	Method and Description
void	cancelAll()
org.apache.hadoop.hbase.client.ResultBoundedCompletionService.QueueingFuture<V>	poll(long timeout, TimeUnit unit)
void	submit(RetryingCallable<V> task, int callTimeout, int id)
org.apache.hadoop.hbase.client.ResultBoundedCompletionService.QueueingFuture<V>	take()

Methods inherited from class java.lang.Object

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

Constructor Detail

ResultBoundedCompletionService

public ResultBoundedCompletionService(RpcRetryingCallerFactory retryingCallerFactory,
                                      Executor executor,
                                      int maxTasks)

Method Detail

submit

public void submit(RetryingCallable<V> task,
                   int callTimeout,
                   int id)

take

public org.apache.hadoop.hbase.client.ResultBoundedCompletionService.QueueingFuture<V> take()
                                                                                     throws InterruptedException

Throws:

InterruptedException

poll

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

Throws:

InterruptedException

cancelAll

public void cancelAll()