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 © 2021 Hazelcast, Inc.. All rights reserved.