MapReduceTask (DataAwareExplorer)

java.lang.Object
- java.util.concurrent.ForkJoinTask<V>
- - java.util.concurrent.RecursiveTask<Output<T>>
  - - org.processmining.dataawareexplorer.parallel.MapReduceTask<T>

Type Parameters:

T - the type of the result computed by the job

All Implemented Interfaces:

java.io.Serializable, java.util.concurrent.Future<Output<T>>
```
public class MapReduceTask<T>
extends java.util.concurrent.RecursiveTask<Output<T>>
```
A ForkJoinTask to be used for generic Map/Reduce computations. Needs to be initialized with an input entity and provides an output entity upon successful execution.

Author:

patrick.peschlow

See Also:

Serialized Form

- Constructor Summary
  
  Constructors
  Constructor Description
  
  MapReduceTask(Input<T> input)
- Method Summary
  
  All Methods Instance Methods Concrete Methods
  Modifier and Type Method Description
  
  protected Output<T> compute()
  - Methods inherited from class java.util.concurrent.RecursiveTask
    exec, getRawResult, setRawResult
  - Methods inherited from class java.util.concurrent.ForkJoinTask
    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, pollSubmission, pollTask, quietlyComplete, quietlyInvoke, quietlyJoin, reinitialize, setForkJoinTaskTag, tryUnfork
  - Methods inherited from class java.lang.Object
    clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

- Constructor Detail
  - MapReduceTask
```
public MapReduceTask(Input<T> input)
```
- Method Detail
  - compute
```
protected Output<T> compute()
```
    Specified by:
    
    compute in class java.util.concurrent.RecursiveTask<Output<T>>