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