Uses of Class
com.hazelcast.jet.datamodel.TimestampedItem

Packages that use TimestampedItem

Package	Description
com.hazelcast.jet.pipeline	The Pipeline API is Jet's high-level API to build and execute distributed computation jobs.

Uses of TimestampedItem in com.hazelcast.jet.pipeline

Methods in com.hazelcast.jet.pipeline that return types with arguments of type TimestampedItem

Modifier and Type	Method and Description
default <A,R> StreamStage<TimestampedItem<R>>	StageWithWindow.aggregate(AggregateOperation1<? super T,A,R> aggrOp) Attaches to this stage a stage that performs the given aggregate operation over all the items that belong to a given window.
default <T1,A,R> StreamStage<TimestampedItem<R>>	StageWithWindow.aggregate2(StreamStage<T1> stage1, AggregateOperation2<? super T,? super T1,A,R> aggrOp) Attaches to this stage a stage that performs the given aggregate operation over all the items that belong to the same window.
default <T1,T2,A,R> StreamStage<TimestampedItem<R>>	StageWithWindow.aggregate3(StreamStage<T1> stage1, StreamStage<T2> stage2, AggregateOperation3<? super T,? super T1,? super T2,A,R> aggrOp) Attaches to this stage a stage that performs the given aggregate operation over the items it receives from this stage as well as stage1 and stage2 you supply.
<A,R> StreamStage<TimestampedItem<R>>	WindowAggregateBuilder.build(AggregateOperation<A,R> aggrOp) Convenience for build(aggrOp, mapToOutputFn) which emits TimestampedItems as output.