R- result type of aggregation
A- argument type being aggregated
public abstract class Aggregator<R,A> extends Object implements ReadFunction<R>
calculate(java.util.List) to aggregate
the values of the current time slice. If no values were collected in the
current time slice, the last value (and only the last value, is passed
so that the output remains consistent with what would be currently
posted. Non calculation is done if no values were collected in the current
and in the previous time slice.
|Modifier||Constructor and Description|
Creates a new aggregator.
|Modifier and Type||Method and Description|
Calculates the new value from a set of collected value.
Calculates, if needed, and then returns the value for this function.
public final R readValue()
Copyright © 2015. All rights reserved.