## Uses of Class
com.hazelcast.jet.datamodel.TimestampedItem

- Packages that use TimestampedItem
  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 TimestampedItem in com.hazelcast.jet.datamodel

    Methods in com.hazelcast.jet.datamodel that return TimestampedItem
    Modifier and Type | Method and Description
    --- | ---
    `static <V> TimestampedItem<V>` | TimestampedItem.`fromWindowResult(long winStart, long winEnd, V value)` This method matches the shape of the functional interface `WindowResultFunction`.

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

    Methods in com.hazelcast.jet.pipeline that return types with arguments of type TimestampedItem
    Modifier and Type | Method and Description
    --- | ---
    `default <R> StreamStage<TimestampedItem<R>>` | StageWithWindow.`aggregate(AggregateOperation1<? super T,?,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<TimestampedItem<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 operation over the items from both this stage and `stage1` you supply.
    `default <T1,R> StreamStage<TimestampedItem<R>>` | StageWithWindow.`aggregate2(StreamStage<T1> stage1, AggregateOperation2<? super T,? super T1,?,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<TimestampedItem<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.
    `default <T1,T2,R> StreamStage<TimestampedItem<R>>` | StageWithWindow.`aggregate3(StreamStage<T1> stage1, StreamStage<T2> stage2, AggregateOperation3<? super T,? super T1,? super T2,?,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<TimestampedItem<ItemsByTag>>` | WindowAggregateBuilder.`build()` Convenience for `build(mapToOutputFn)` which emits `TimestampedItem`s as output.
    `<A,R> StreamStage<TimestampedItem<R>>` | WindowAggregateBuilder1.`build(AggregateOperation<A,R> aggrOp)` Convenience for `build(aggrOp, mapToOutputFn)` which emits `TimestampedItem`s as output.
    `default StreamStage<TimestampedItem<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).
    `default StreamStage<TimestampedItem<T>>` | StageWithKeyAndWindow.`distinct()` 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.