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 |
---|---|
LinTrendAccumulator |
LinTrendAccumulator.accumulate(long x,
long y)
Accumulates a new sample.
|
LinTrendAccumulator |
LinTrendAccumulator.combine(LinTrendAccumulator that)
Combines this accumulator with the supplied one.
|
LinTrendAccumulator |
LinTrendAccumulator.deduct(LinTrendAccumulator that)
Deducts the supplied accumulator from this one.
|
Modifier and Type | Method and Description |
---|---|
LinTrendAccumulator |
LinTrendAccumulator.combine(LinTrendAccumulator that)
Combines this accumulator with the supplied one.
|
LinTrendAccumulator |
LinTrendAccumulator.deduct(LinTrendAccumulator that)
Deducts the supplied accumulator from this one.
|
Modifier and Type | Method and Description |
---|---|
static <T> AggregateOperation1<T,LinTrendAccumulator,Double> |
AggregateOperations.linearTrend(DistributedToLongFunction<T> getXFn,
DistributedToLongFunction<T> getYFn)
Returns an operation that computes a linear trend on the items in the
window.
|
Copyright © 2017 Hazelcast, Inc.. All Rights Reserved.