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.Exception
VortexAggregateException
Copyright © 2016 The Apache Software Foundation. All rights reserved.