Package | Description |
---|---|
org.apache.hadoop.hbase.client |
Provides HBase Client
|
Modifier and Type | Field and Description |
---|---|
private ResultBoundedCompletionService.QueueingFuture<V>[] |
ResultBoundedCompletionService.tasks |
Modifier and Type | Field and Description |
---|---|
private ArrayList<ResultBoundedCompletionService.QueueingFuture> |
ResultBoundedCompletionService.completedTasks |
Modifier and Type | Method and Description |
---|---|
ResultBoundedCompletionService.QueueingFuture<V> |
ResultBoundedCompletionService.poll(long timeout,
TimeUnit unit)
Poll for the first completed task whether it is a success or execution exception.
|
ResultBoundedCompletionService.QueueingFuture<V> |
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) range
|
private ResultBoundedCompletionService.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.QueueingFuture<V> |
ResultBoundedCompletionService.take() |
Copyright © 2007–2020 The Apache Software Foundation. All rights reserved.