Uses of Class
org.apache.hadoop.hbase.client.ResultBoundedCompletionService.QueueingFuture
-
Uses of ResultBoundedCompletionService.QueueingFuture in org.apache.hadoop.hbase.client
Modifier and TypeFieldDescriptionprivate final ResultBoundedCompletionService<V>.QueueingFuture<V>[]
ResultBoundedCompletionService.tasks
Modifier and TypeFieldDescriptionprivate final ArrayList<ResultBoundedCompletionService.QueueingFuture>
ResultBoundedCompletionService.completedTasks
Modifier and TypeMethodDescriptionPoll for the first completed task whether it is a success or execution exception.ResultBoundedCompletionService.pollForFirstSuccessfullyCompletedTask
(long timeout, TimeUnit unit, int startIndex, int endIndex) Poll for the first successfully completed task whose completed order is in startIndex, endIndex(exclusive) rangeprivate ResultBoundedCompletionService<V>.QueueingFuture<V>
ResultBoundedCompletionService.pollForSpecificCompletedTask
(long timeout, TimeUnit unit, int index) Poll for the Nth completed task (index starts from 0 (the 1st), 1 (the second)...)ResultBoundedCompletionService.take()