public interface GlobalAggregateManager
Modifier and Type | Method and Description |
---|---|
<IN,ACC,OUT> |
updateGlobalAggregate(String aggregateName,
Object aggregand,
AggregateFunction<IN,ACC,OUT> aggregateFunction)
Update the global aggregate and return the new value.
|
<IN,ACC,OUT> OUT updateGlobalAggregate(String aggregateName, Object aggregand, AggregateFunction<IN,ACC,OUT> aggregateFunction) throws IOException
aggregateName
- The name of the aggregate to updateaggregand
- The value to add to the aggregateaggregateFunction
- The function to apply to the current aggregate and aggregand to
obtain the new aggregate valueIOException
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.