Package | Description |
---|---|
org.processmining.dataawareexplorer.parallel |
Modifier and Type | Method and Description |
---|---|
protected Output<T> |
MapReduceTask.compute() |
Output<T> |
Input.computeDirectly()
Performs the computation for this entity directly (i.e., the map phase of
the job) and returns the output object carrying the result for this
entity.
|
Output<T> |
Output.reduce(Output<T> other)
Reduces this output entity with another output entity.
|
Modifier and Type | Method and Description |
---|---|
Output<T> |
Output.reduce(Output<T> other)
Reduces this output entity with another output entity.
|