Uses of Class
com.hazelcast.jet.datamodel.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 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 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 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.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).