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.
|
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 . |
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> |
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 Hazelcast, Inc.. All rights reserved.