T
- the type of the result computed by the jobpublic class MapReduceTask<T> extends java.util.concurrent.RecursiveTask<Output<T>>
Constructor and Description |
---|
MapReduceTask(Input<T> input) |
Modifier and Type | Method and Description |
---|---|
protected Output<T> |
compute() |
adapt, adapt, adapt, cancel, compareAndSetForkJoinTaskTag, complete, completeExceptionally, fork, get, get, getException, getForkJoinTaskTag, getPool, getQueuedTaskCount, getSurplusQueuedTaskCount, helpQuiesce, inForkJoinPool, invoke, invokeAll, invokeAll, invokeAll, isCancelled, isCompletedAbnormally, isCompletedNormally, isDone, join, peekNextLocalTask, pollNextLocalTask, pollTask, quietlyComplete, quietlyInvoke, quietlyJoin, reinitialize, setForkJoinTaskTag, tryUnfork