Package | Description |
---|---|
com.hazelcast.jet.accumulator |
Classes intended to be used for accumulator objects in Jet aggregation
operations.
|
com.hazelcast.jet.aggregate |
Contains
AggregateOperation and several its 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.
|
LongAccumulator |
LongAccumulator.add(LongAccumulator that)
Adds the value of the supplied accumulator to this accumulator.
|
LongAccumulator |
LongAccumulator.addExact(long value)
Uses
Math.addExact() to add the
supplied value to this accumulator. |
LongAccumulator |
LongAccumulator.addExact(LongAccumulator that)
Uses
Math.addExact() to add the value
of the supplied accumulator into this one. |
LongAccumulator |
LongAccumulator.set(long value)
Sets the value as given.
|
LongAccumulator |
LongAccumulator.subtract(LongAccumulator that)
Subtracts the value of the supplied accumulator from this one.
|
LongAccumulator |
LongAccumulator.subtractExact(LongAccumulator that)
Uses
Math.subtractExact()
to subtract the value of the supplied accumulator from this one. |
Modifier and Type | Method and Description |
---|---|
LongAccumulator |
LongAccumulator.add(LongAccumulator that)
Adds the value of the supplied accumulator to this accumulator.
|
LongAccumulator |
LongAccumulator.addExact(LongAccumulator that)
Uses
Math.addExact() to add the value
of the supplied accumulator into this one. |
LongAccumulator |
LongAccumulator.subtract(LongAccumulator that)
Subtracts the value of the supplied accumulator from this one.
|
LongAccumulator |
LongAccumulator.subtractExact(LongAccumulator that)
Uses
Math.subtractExact()
to subtract the value of the supplied accumulator from this one. |
Modifier and Type | Method and Description |
---|---|
static <T> AggregateOperation1<T,LongAccumulator,Long> |
AggregateOperations.counting()
Returns an operation that tracks the count of items in the window.
|
static <T> AggregateOperation1<T,LongAccumulator,Long> |
AggregateOperations.summingLong(DistributedToLongFunction<T> getLongValueFn)
Returns an operation that tracks the sum of the quantity returned by
getLongValueFn applied to each item in the window. |
Copyright © 2017 Hazelcast, Inc.. All Rights Reserved.