TOutput - output type of the aggregation function and the functions to-be-aggregated.public interface VortexAggregateFunction<TOutput>
| Modifier and Type | Method and Description |
|---|---|
TOutput |
call(List<TOutput> taskletOutputs)
Runs a custom local aggregation function on Tasklets assigned to a VortexWorker.
|
TOutput call(List<TOutput> taskletOutputs) throws VortexAggregateException
taskletOutputs - the list of outputs from Tasklets on a Worker.ExceptionVortexAggregateExceptionCopyright © 2016 The Apache Software Foundation. All rights reserved.