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

Packages that use TimestampedEntry

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

Uses of TimestampedEntry in com.hazelcast.jet.pipeline

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

Modifier and Type	Method and Description
<A,R> StreamStage<TimestampedEntry<K,R>>	StageWithGroupingAndWindow.aggregate(AggregateOperation1<? super T,A,R> aggrOp) Attaches to this stage a stage that performs the given group-and-aggregate operation.
<T1,A,R> StreamStage<TimestampedEntry<K,R>>	StageWithGroupingAndWindow.aggregate2(StreamStageWithGrouping<T1,? extends K> stage1, AggregateOperation2<? super T,? super T1,A,R> aggrOp) Attaches to this stage a stage that performs the given cogroup-and-aggregate operation over the items from both this stage and stage1 you supply.
<T1,T2,A,R> StreamStage<TimestampedEntry<K,R>>	StageWithGroupingAndWindow.aggregate3(StreamStageWithGrouping<T1,? extends K> stage1, StreamStageWithGrouping<T2,? extends K> stage2, AggregateOperation3<? super T,? super T1,? super T2,A,R> aggrOp) Attaches to this stage a stage that performs the given cogroup-and-aggregate operation over the items from this stage as well as stage1 and stage2 you supply.
<A,R> StreamStage<TimestampedEntry<K,R>>	WindowGroupAggregateBuilder.build(AggregateOperation<A,R> aggrOp) Convenience for WindowGroupAggregateBuilder.build(AggregateOperation, KeyedWindowResultFunction) which results in a stage that emits TimestampedEntrys.