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 |
---|---|
default <T1,R0,R1,OUT> |
StageWithWindow.aggregate2(AggregateOperation1<? super T,?,? extends R0> aggrOp0,
StreamStage<T1> stage1,
AggregateOperation1<? super T1,?,? extends R1> aggrOp1,
WindowResult2Function<? super R0,? super R1,? extends OUT> mapToOutputFn)
Attaches a stage that performs the given co-aggregate operation over the
items from both this stage and
stage1 you supply. |
Copyright © 2018 Hazelcast, Inc.. All rights reserved.