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 |
---|---|
DoubleAccumulator |
DoubleAccumulator.add(double v)
Adds the value of to this objects' value.
|
DoubleAccumulator |
DoubleAccumulator.add(DoubleAccumulator that)
Adds the value of the supplied accumulator to this one.
|
DoubleAccumulator |
DoubleAccumulator.set(double value)
Sets the value as given.
|
DoubleAccumulator |
DoubleAccumulator.subtract(DoubleAccumulator that)
Subtracts the value of the supplied accumulator from this one.
|
Modifier and Type | Method and Description |
---|---|
DoubleAccumulator |
DoubleAccumulator.add(DoubleAccumulator that)
Adds the value of the supplied accumulator to this one.
|
DoubleAccumulator |
DoubleAccumulator.subtract(DoubleAccumulator that)
Subtracts the value of the supplied accumulator from this one.
|
Modifier and Type | Method and Description |
---|---|
static <T> AggregateOperation1<T,DoubleAccumulator,Double> |
AggregateOperations.summingDouble(DistributedToDoubleFunction<T> getDoubleValueFn)
Returns an operation that tracks the sum of the quantity returned by
getDoubleValueFn applied to each item in the window. |
Copyright © 2017 Hazelcast, Inc.. All Rights Reserved.