Uses of Class
org.apache.hadoop.util.functional.TaskPool.Builder

Packages that use TaskPool.Builder

Package	Description
org.apache.hadoop.util.functional	Support for functional programming within the Hadoop APIs.

Uses of TaskPool.Builder in org.apache.hadoop.util.functional

Methods in org.apache.hadoop.util.functional that return TaskPool.Builder

Modifier and Type	Method	Description
TaskPool.Builder<I>	TaskPool.Builder.abortWith(TaskPool.Task<I,?> task)	Task to abort with after another task failed.
TaskPool.Builder<I>	TaskPool.Builder.executeWith(TaskPool.Submitter submitter)	Declare executor service: if null, the tasks are executed in a single thread.
static <I> TaskPool.Builder<I>	TaskPool.foreach(I[] items)
static <I> TaskPool.Builder<I>	TaskPool.foreach(Iterable<I> items)	Create a task builder for the iterable.
static <I> TaskPool.Builder<I>	TaskPool.foreach(RemoteIterator<I> items)	Create a task builder for the remote iterator.
TaskPool.Builder<I>	TaskPool.Builder.onFailure(TaskPool.FailureTask<I,?> task)	Task to invoke on failure.
TaskPool.Builder<I>	TaskPool.Builder.revertWith(TaskPool.Task<I,?> task)	Task to revert with after another task failed.
TaskPool.Builder<I>	TaskPool.Builder.sleepInterval(int value)	Set the sleep interval.
TaskPool.Builder<I>	TaskPool.Builder.stopAbortsOnFailure()	Stop trying to abort if one operation fails.
TaskPool.Builder<I>	TaskPool.Builder.stopOnFailure()
TaskPool.Builder<I>	TaskPool.Builder.stopRevertsOnFailure()	Stop trying to revert if one operation fails.
TaskPool.Builder<I>	TaskPool.Builder.suppressExceptions()	Suppress exceptions from tasks.
TaskPool.Builder<I>	TaskPool.Builder.suppressExceptions(boolean suppress)	Suppress exceptions from tasks.