Package com.hazelcast.jet.aggregate
Interface AggregateOperation1<T,A,R>
-
- Type Parameters:
T
- the type of the stream itemA
- the type of the accumulatorR
- the type of the aggregation result
- All Superinterfaces:
AggregateOperation<A,R>
,java.io.Serializable
public interface AggregateOperation1<T,A,R> extends AggregateOperation<A,R>
Specialization ofAggregateOperation
(refer to its extensive documentation) to the "arity-1" case with a single data stream being aggregated over.AggregateOperations
contains factories for the built-in implementations and you can create your own using the aggregate operation builder.All the functions must be stateless and cooperative.
- Since:
- Jet 3.0
-
-
Method Summary
All Methods Instance Methods Abstract Methods Default Methods Deprecated Methods Modifier and Type Method Description BiConsumerEx<? super A,? super T>
accumulateFn()
A primitive that updates the accumulator state to account for a new item.<R_NEW> AggregateOperation1<T,A,R_NEW>
andThen(FunctionEx<? super R,? extends R_NEW> thenFn)
Returns a copy of this aggregate operation, but with theexport
andfinish
primitives composed with the suppliedthenFn
.default java.util.stream.Collector<T,A,R>
toCollector()
Deprecated.<NEW_T> AggregateOperation1<NEW_T,A,R>
withAccumulateFn(BiConsumerEx<? super A,? super NEW_T> accumulateFn)
Returns a copy of this aggregate operation, but with theaccumulate
primitive replaced with the one supplied here.AggregateOperation1<T,A,A>
withIdentityFinish()
Returns a copy of this aggregate operation, but with thefinish
primitive replaced with the identity function.-
Methods inherited from interface com.hazelcast.jet.aggregate.AggregateOperation
accumulateFn, accumulateFn, arity, combineFn, createFn, deductFn, exportFn, finishFn, withAccumulateFns, withCombiningAccumulateFn
-
-
-
-
Method Detail
-
accumulateFn
@Nonnull BiConsumerEx<? super A,? super T> accumulateFn()
A primitive that updates the accumulator state to account for a new item.The consumer must be stateless and cooperative.
-
withAccumulateFn
@Nonnull <NEW_T> AggregateOperation1<NEW_T,A,R> withAccumulateFn(BiConsumerEx<? super A,? super NEW_T> accumulateFn)
Returns a copy of this aggregate operation, but with theaccumulate
primitive replaced with the one supplied here.The consumer must be stateless and cooperative.
-
withIdentityFinish
@Nonnull AggregateOperation1<T,A,A> withIdentityFinish()
Description copied from interface:AggregateOperation
Returns a copy of this aggregate operation, but with thefinish
primitive replaced with the identity function. It will return the accumulator object as-is. The returned aggregate operation does not support theexport
primitive.- Specified by:
withIdentityFinish
in interfaceAggregateOperation<T,A>
-
andThen
@Nonnull <R_NEW> AggregateOperation1<T,A,R_NEW> andThen(FunctionEx<? super R,? extends R_NEW> thenFn)
Description copied from interface:AggregateOperation
Returns a copy of this aggregate operation, but with theexport
andfinish
primitives composed with the suppliedthenFn
. This replacesexportFn
withexportFn.andThen(thenFn)
, same forfinishFn
. The main use case is to transform the result of an existing (library-provided) aggregate operation.The given function must be stateless and cooperative.
- Specified by:
andThen
in interfaceAggregateOperation<T,A>
- Type Parameters:
R_NEW
- the type of the returned aggregate operation's result- Parameters:
thenFn
- the function to apply to the results ofexport
andfinish
primitives
-
-