Package | Description |
---|---|
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.
|
Modifier and Type | Method and Description |
---|---|
default KeyedWindowResult3Function<Object,R0,R1,R2,OUT> |
WindowResult3Function.toKeyedWindowResult3Fn() |
Modifier and Type | Method and Description |
---|---|
default <T1,T2,R0,R1,R2,OUT> |
StageWithKeyAndWindow.aggregate3(AggregateOperation1<? super T,?,? extends R0> aggrOp0,
StreamStageWithKey<T1,? extends K> stage1,
AggregateOperation1<? super T1,?,? extends R1> aggrOp1,
StreamStageWithKey<T2,? extends K> stage2,
AggregateOperation1<? super T2,?,? extends R2> aggrOp2,
KeyedWindowResult3Function<? super K,? super R0,? super R1,? super R2,? 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. |
Copyright © 2018 Hazelcast, Inc.. All rights reserved.