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 |
---|---|
<K> StageWithGrouping<T,K> |
BatchStage.groupingKey(DistributedFunction<? super T,? extends K> keyFn) |
Modifier and Type | Method and Description |
---|---|
<T> Tag<T> |
GroupAggregateBuilder.add(StageWithGrouping<T,K> stage)
Adds another stage that will contribute its data to the aggregate
operation to be performed.
|
default <T1,A,R> BatchStage<Map.Entry<K,R>> |
StageWithGrouping.aggregate2(StageWithGrouping<T1,? extends K> stage1,
AggregateOperation2<? super T,? super T1,A,R> aggrOp)
Attaches to this stage a stage that performs the given
cogroup-and-aggregate operation over the items from both this stage
and
stage1 you supply. |
<T1,A,R,OUT> |
StageWithGrouping.aggregate2(StageWithGrouping<T1,? extends K> stage1,
AggregateOperation2<? super T,? super T1,A,R> aggrOp,
DistributedBiFunction<? super K,? super R,OUT> mapToOutputFn)
Attaches to this stage a stage that performs the given
cogroup-and-aggregate operation over the items from both this stage
and
stage1 you supply. |
default <T1,T2,A,R> |
StageWithGrouping.aggregate3(StageWithGrouping<T1,? extends K> stage1,
StageWithGrouping<T2,? extends K> stage2,
AggregateOperation3<? super T,? super T1,? super T2,A,R> aggrOp)
Attaches to this stage a stage that performs the given
cogroup-and-aggregate operation over the items from this stage as well
as
stage1 and stage2 you supply. |
default <T1,T2,A,R> |
StageWithGrouping.aggregate3(StageWithGrouping<T1,? extends K> stage1,
StageWithGrouping<T2,? extends K> stage2,
AggregateOperation3<? super T,? super T1,? super T2,A,R> aggrOp)
Attaches to this stage a stage that performs the given
cogroup-and-aggregate operation over the items from this stage as well
as
stage1 and stage2 you supply. |
<T1,T2,A,R,OUT> |
StageWithGrouping.aggregate3(StageWithGrouping<T1,? extends K> stage1,
StageWithGrouping<T2,? extends K> stage2,
AggregateOperation3<? super T,? super T1,? super T2,A,R> aggrOp,
DistributedBiFunction<? super K,? super R,OUT> mapToOutputFn)
Attaches to this stage a stage that performs the given
cogroup-and-aggregate operation over the items from this stage as well
as
stage1 and stage2 you supply. |
<T1,T2,A,R,OUT> |
StageWithGrouping.aggregate3(StageWithGrouping<T1,? extends K> stage1,
StageWithGrouping<T2,? extends K> stage2,
AggregateOperation3<? super T,? super T1,? super T2,A,R> aggrOp,
DistributedBiFunction<? super K,? super R,OUT> mapToOutputFn)
Attaches to this stage a stage that performs the given
cogroup-and-aggregate operation over the items from this stage as well
as
stage1 and stage2 you supply. |
Copyright © 2018 Hazelcast, Inc.. All rights reserved.