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

- Packages that use KeyedWindowResultFunction
  Package | Description
  --- | ---
  com.hazelcast.jet.core.processor | Contains static utility classes with factories of Jet processors.
  com.hazelcast.jet.function | Serializable and exception-declaring variants of functional interfaces from `java.util.function`.
  com.hazelcast.jet.pipeline | The Pipeline API is Jet's high-level API to build and execute distributed computation jobs.

- - ### Uses of KeyedWindowResultFunction in com.hazelcast.jet.core.processor

    Methods in com.hazelcast.jet.core.processor with parameters of type KeyedWindowResultFunction
    Modifier and Type | Method and Description
    --- | ---
    `static <K,A,R,OUT> DistributedSupplier<Processor>` | Processors.`aggregateToSessionWindowP(long sessionTimeout, List<DistributedToLongFunction<?>> timestampFns, List<DistributedFunction<?,? extends K>> keyFns, AggregateOperation<A,R> aggrOp, KeyedWindowResultFunction<? super K,? super R,OUT> mapToOutputFn)` Returns a supplier of processors for a vertex that aggregates events into session windows.
    `static <K,A,R,OUT> DistributedSupplier<Processor>` | Processors.`aggregateToSlidingWindowP(List<DistributedFunction<?,? extends K>> keyFns, List<DistributedToLongFunction<?>> timestampFns, TimestampKind timestampKind, SlidingWindowPolicy winPolicy, AggregateOperation<A,R> aggrOp, KeyedWindowResultFunction<? super K,? super R,OUT> mapToOutputFn)` Returns a supplier of processors for a vertex that aggregates events into a sliding window in a single stage (see the `class Javadoc` for an explanation of aggregation stages).
    `static <K,A,R,OUT> DistributedSupplier<Processor>` | Processors.`combineToSlidingWindowP(SlidingWindowPolicy winPolicy, AggregateOperation<A,R> aggrOp, KeyedWindowResultFunction<? super K,? super R,OUT> mapToOutputFn)` Returns a supplier of processors for the second-stage vertex in a two-stage sliding window aggregation setup (see the `class Javadoc` for an explanation of aggregation stages).

  - ### Uses of KeyedWindowResultFunction in com.hazelcast.jet.function

    Methods in com.hazelcast.jet.function that return KeyedWindowResultFunction
    Modifier and Type | Method and Description
    --- | ---
    `default KeyedWindowResultFunction<Object,R,OUT>` | WindowResultFunction.`toKeyedWindowResultFn()`

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

    Methods in com.hazelcast.jet.pipeline with parameters of type KeyedWindowResultFunction
    Modifier and Type | Method and Description
    --- | ---
    `<R,OUT> StreamStage<OUT>` | StageWithKeyAndWindow.`aggregate(AggregateOperation1<? super T,?,? extends R> aggrOp, KeyedWindowResultFunction<? super K,? super R,? extends OUT> mapToOutputFn)` Attaches a stage that performs the given group-and-aggregate operation over the window described by the window definition captured by this object.
    `<T1,R,OUT> StreamStage<OUT>` | StageWithKeyAndWindow.`aggregate2(StreamStageWithKey<T1,? extends K> stage1, AggregateOperation2<? super T,? super T1,?,? extends R> aggrOp, KeyedWindowResultFunction<? super K,? super R,? extends OUT> mapToOutputFn)` Attaches a stage that performs the given cogroup-and-aggregate operation over the items from both this stage and `stage1` you supply.
    `<T1,T2,R,OUT> StreamStage<OUT>` | StageWithKeyAndWindow.`aggregate3(StreamStageWithKey<T1,? extends K> stage1, StreamStageWithKey<T2,? extends K> stage2, AggregateOperation3<? super T,? super T1,? super T2,?,? extends R> aggrOp, KeyedWindowResultFunction<? super K,? super R,? extends OUT> mapToOutputFn)` Attaches a stage that performs the given cogroup-and-aggregate operation over the items from this stage as well as `stage1` and `stage2` you supply.
    `<R,OUT> StreamStage<OUT>` | WindowGroupAggregateBuilder1.`build(AggregateOperation<?,R> aggrOp, KeyedWindowResultFunction<? super K,? super R,OUT> mapToOutputFn)` Creates and returns a pipeline stage that performs a windowed cogroup-and-aggregate of the pipeline stages registered with this builder object.
    `<OUT> StreamStage<OUT>` | WindowGroupAggregateBuilder.`build(KeyedWindowResultFunction<? super K,ItemsByTag,OUT> mapToOutputFn)` Creates and returns a pipeline stage that performs a windowed cogroup-and-aggregate operation on the stages registered with this builder object.

Copyright © 2018. All rights reserved.