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,R> ComputeStage<Map.Entry<K,R>> |
ComputeStage.coGroup(DistributedFunction<? super E,? extends K> thisKeyFn,
ComputeStage<E1> stage1,
DistributedFunction<? super E1,? extends K> key1Fn,
AggregateOperation2<? super E,? super E1,A,R> aggrOp)
Attaches to this and the supplied stage 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> AggregateOperation2<T0,T1,A,R> |
AggregateOperationBuilder.Arity2.andFinish(DistributedFunction<? super A,R> finishFn)
Constructs and returns an
AggregateOperation2 from the
current state of the builder and the supplied finish primitive. |
AggregateOperation2<T0,T1,A,A> |
AggregateOperationBuilder.Arity2.andIdentityFinish()
Constructs and returns an
AggregateOperation2 from the current
state of the builder, with the identity function as the finish primitive. |
<R1> AggregateOperation2<T0,T1,A,R1> |
AggregateOperation2.withFinishFn(DistributedFunction<? super A,R1> finishFn) |
Copyright © 2017 Hazelcast, Inc.. All Rights Reserved.