## Uses of Interface
com.hazelcast.jet.function.WindowResultFunction

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

- - ### Uses of WindowResultFunction in com.hazelcast.jet.pipeline

    Methods in com.hazelcast.jet.pipeline with parameters of type WindowResultFunction
    Modifier and Type | Method and Description
    --- | ---
    `<R,OUT> StreamStage<OUT>` | StageWithWindow.`aggregate(AggregateOperation1<? super T,?,? extends R> aggrOp, WindowResultFunction<? super R,? extends OUT> mapToOutputFn)` Attaches a stage that performs the given aggregate operation over all the items that belong to a given window.
    `<T1,R,OUT> StreamStage<OUT>` | StageWithWindow.`aggregate2(StreamStage<T1> stage1, AggregateOperation2<? super T,? super T1,?,R> aggrOp, WindowResultFunction<? super R,? extends OUT> mapToOutputFn)` Attaches a stage that performs the given aggregate operation over all the items that belong to the same window.
    `<T1,T2,R,OUT> StreamStage<OUT>` | StageWithWindow.`aggregate3(StreamStage<T1> stage1, StreamStage<T2> stage2, AggregateOperation3<? super T,? super T1,? super T2,?,R> aggrOp, WindowResultFunction<? super R,? extends OUT> mapToOutputFn)` 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.
    `<R,OUT> StreamStage<OUT>` | WindowAggregateBuilder1.`build(AggregateOperation<?,R> aggrOp, WindowResultFunction<? super R,? extends OUT> mapToOutputFn)` Creates and returns a pipeline stage that performs a windowed co-aggregation of the pipeline stages registered with this builder object.
    `<OUT> StreamStage<OUT>` | WindowAggregateBuilder.`build(WindowResultFunction<? super ItemsByTag,? extends OUT> mapToOutputFn)` Creates and returns a pipeline stage that performs a windowed co-aggregation of the stages registered with this builder object.
    `default <R> StreamStage<R>` | StageWithWindow.`distinct(WindowResultFunction<? super T,? extends R> mapToOutputFn)` Attaches a stage that passes through just the items that are distinct within their window (no two items emitted for a window are equal).
    `default <R> StreamStage<R>` | StageWithKeyAndWindow.`distinct(WindowResultFunction<? super T,? extends R> mapToOutputFn)` Attaches a stage that passes through just the items that are distinct within their window according to the grouping key (no two items emitted for a window map to the same key).

Copyright © 2018. All rights reserved.