Uses of Class
com.hazelcast.jet.datamodel.WindowResult
Package
Description
Generic data containers used by the Pipeline API.
The Pipeline API is Jet's high-level API to build and execute
distributed computation jobs.
-
Uses of WindowResult in com.hazelcast.jet.datamodel
Modifier and TypeClassDescriptionfinal class
KeyedWindowResult<K,
R> Holds the result of a group-and-aggregate operation performed over a time window. -
Uses of WindowResult in com.hazelcast.jet.pipeline
Modifier and TypeMethodDescription<R> StreamStage<WindowResult<R>>
StageWithWindow.aggregate
(AggregateOperation1<? super T, ?, ? extends R> aggrOp) Attaches a stage that performs the given aggregate operation over all the items that belong to a given window.default <T1,
R0, R1> StreamStage<WindowResult<Tuple2<R0, R1>>> StageWithWindow.aggregate2
(AggregateOperation1<? super T, ?, ? extends R0> aggrOp0, StreamStage<T1> stage1, AggregateOperation1<? super T1, ?, ? extends R1> aggrOp1) Attaches a stage that performs the given co-aggregate operations over the items from this stage andstage1
you supply.<T1,
R> StreamStage<WindowResult<R>> StageWithWindow.aggregate2
(StreamStage<T1> stage1, AggregateOperation2<? super T, ? super T1, ?, ? extends R> aggrOp) Attaches a stage that performs the given aggregate operation over all the items that belong to the same window.default <T1,
T2, R0, R1, R2>
StreamStage<WindowResult<Tuple3<R0,R1, R2>>> StageWithWindow.aggregate3
(AggregateOperation1<? super T, ?, ? extends R0> aggrOp0, StreamStage<T1> stage1, AggregateOperation1<? super T1, ?, ? extends R1> aggrOp1, StreamStage<T2> stage2, AggregateOperation1<? super T2, ?, ? extends R2> aggrOp2) Attaches a stage that performs the given aggregate operation over all the items that belong to the same window.<T1,
T2, R> StreamStage<WindowResult<R>> StageWithWindow.aggregate3
(StreamStage<T1> stage1, StreamStage<T2> stage2, AggregateOperation3<? super T, ? super T1, ? super T2, ?, ? extends R> aggrOp) Attaches a stage that performs the given aggregate operation over the items it receives from this stage as well asstage1
andstage2
you supply.WindowAggregateBuilder.build()
Creates and returns a pipeline stage that performs a windowed co-aggregation of the stages registered with this builder object.<A,
R> StreamStage<WindowResult<R>> WindowAggregateBuilder1.build
(AggregateOperation<A, R> aggrOp) Creates and returns a pipeline stage that performs a windowed co-aggregation of the pipeline stages registered with this builder object.default StreamStage<WindowResult<T>>
StageWithWindow.distinct()
Attaches a stage that passes through just the items that are distinct within their window (no two items emitted for a window are equal).