| Package | Description | 
|---|---|
| com.hazelcast.jet.accumulator | 
 Classes intended to be used for accumulator objects in an  
AggregateOperation. | 
| com.hazelcast.jet.aggregate | 
 Contains  
AggregateOperation and its several variants, as well
 as a builder object for the aggregate operations. | 
| Modifier and Type | Method and Description | 
|---|---|
LongAccumulator | 
LongAccumulator.add(long value)
Adds the supplied value to this accumulator, throwing an exception
 in the case of integer overflow. 
 | 
LongAccumulator | 
LongAccumulator.add(LongAccumulator that)
Adds the value of the supplied accumulator to this accumulator, throwing
 an exception in the case of integer overflow. 
 | 
LongAccumulator | 
LongAccumulator.addAllowingOverflow(long value)
Adds the supplied value to this accumulator, allowing integer overflow. 
 | 
LongAccumulator | 
LongAccumulator.addAllowingOverflow(LongAccumulator that)
Adds the value of the supplied accumulator to this accumulator, allowing
 integer overflow. 
 | 
LongAccumulator | 
LongAccumulator.set(long value)
Sets the value as given. 
 | 
LongAccumulator | 
LongAccumulator.subtract(long value)
Subtracts the supplied value from this accumulator, throwing an
 exception in the case of integer overflow. 
 | 
LongAccumulator | 
LongAccumulator.subtract(LongAccumulator that)
Subtracts the value of the supplied accumulator from this one,
 throwing an exception in the case of integer overflow. 
 | 
LongAccumulator | 
LongAccumulator.subtractAllowingOverflow(long value)
Subtracts the supplied value from this accumulator, allowing integer
 overflow. 
 | 
LongAccumulator | 
LongAccumulator.subtractAllowingOverflow(LongAccumulator that)
Subtracts the value of the supplied accumulator from this one, allowing
 integer overflow. 
 | 
| Modifier and Type | Method and Description | 
|---|---|
LongAccumulator | 
LongAccumulator.add(LongAccumulator that)
Adds the value of the supplied accumulator to this accumulator, throwing
 an exception in the case of integer overflow. 
 | 
LongAccumulator | 
LongAccumulator.addAllowingOverflow(LongAccumulator that)
Adds the value of the supplied accumulator to this accumulator, allowing
 integer overflow. 
 | 
LongAccumulator | 
LongAccumulator.subtract(LongAccumulator that)
Subtracts the value of the supplied accumulator from this one,
 throwing an exception in the case of integer overflow. 
 | 
LongAccumulator | 
LongAccumulator.subtractAllowingOverflow(LongAccumulator that)
Subtracts the value of the supplied accumulator from this one, allowing
 integer overflow. 
 | 
| Modifier and Type | Method and Description | 
|---|---|
static <T> AggregateOperation1<T,LongAccumulator,Long> | 
AggregateOperations.counting()
Returns an aggregate operation that counts the items it observes. 
 | 
static <T> AggregateOperation1<T,LongAccumulator,Long> | 
AggregateOperations.summingLong(ToLongFunctionEx<? super T> getLongValueFn)
Returns an aggregate operation that computes the sum of the  
long
 values it obtains by applying getLongValueFn to each item. | 
Copyright © 2023 Hazelcast, Inc.. All rights reserved.