Package | Description |
---|---|
com.hazelcast.jet |
The Pipeline API is Jet's high-level API to build and execute
distributed computation jobs.
|
com.hazelcast.jet.aggregate |
Contains
AggregateOperation and several its variants, as well
as a builder object for the aggregate operations. |
Modifier and Type | Method and Description |
---|---|
<K,A,E1,E2,R> |
ComputeStage.coGroup(DistributedFunction<? super E,? extends K> thisKeyFn,
ComputeStage<E1> stage1,
DistributedFunction<? super E1,? extends K> key1Fn,
ComputeStage<E2> stage2,
DistributedFunction<? super E2,? extends K> key2Fn,
AggregateOperation3<? super E,? super E1,? super E2,A,R> aggrOp)
Attaches to this and the supplied stages a stage that co-groups their items
by a common key and applies the supplied aggregate operation to co-grouped
items.
|
Modifier and Type | Method and Description |
---|---|
<R> AggregateOperation3<T0,T1,T2,A,R> |
AggregateOperationBuilder.Arity3.andFinish(DistributedFunction<? super A,R> finishFn)
Constructs and returns an
AggregateOperation3 from the
current state of the builder and the supplied finish primitive. |
AggregateOperation3<T0,T1,T2,A,A> |
AggregateOperationBuilder.Arity3.andIdentityFinish()
Constructs and returns an
AggregateOperation3 from the current
state of the builder, with the identity function as the finish primitive. |
<R1> AggregateOperation3<T0,T1,T2,A,R1> |
AggregateOperation3.withFinishFn(DistributedFunction<? super A,R1> finishFn) |
Copyright © 2017 Hazelcast, Inc.. All Rights Reserved.