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

Packages that use WindowResult

Package	Description
com.hazelcast.jet.datamodel	Generic data containers used by the Pipeline API.
com.hazelcast.jet.pipeline	The Pipeline API is Jet's high-level API to build and execute distributed computation jobs.

Uses of WindowResult in com.hazelcast.jet.datamodel

Subclasses of WindowResult in com.hazelcast.jet.datamodel

Modifier and Type	Class and Description
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

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

Modifier and Type	Method and Description
<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 and stage1 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 as stage1 and stage2 you supply.
StreamStage<WindowResult<ItemsByTag>>	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).