Package | Description |
---|---|
com.hazelcast.jet.aggregate |
Contains
AggregateOperation and several its variants, as well
as a builder object for the aggregate operations. |
com.hazelcast.jet.datamodel |
Generic data containers used by the Pipeline API.
|
Modifier and Type | Method and Description |
---|---|
static <T,A1,A2,R1,R2> |
AggregateOperations.allOf(AggregateOperation1<? super T,A1,R1> op1,
AggregateOperation1<? super T,A2,R2> op2)
Convenience for
AggregateOperations.allOf(AggregateOperation1, AggregateOperation1,
DistributedBiFunction) with identity finish. |
static <T,A1,A2,R1,R2> |
AggregateOperations.allOf(AggregateOperation1<? super T,A1,R1> op1,
AggregateOperation1<? super T,A2,R2> op2)
Convenience for
AggregateOperations.allOf(AggregateOperation1, AggregateOperation1,
DistributedBiFunction) with identity finish. |
static <T,A1,A2,R1,R2,R> |
AggregateOperations.allOf(AggregateOperation1<? super T,A1,R1> op1,
AggregateOperation1<? super T,A2,R2> op2,
DistributedBiFunction<? super R1,? super R2,R> finishFn)
Returns composite aggregate operation from 2 other aggregate operations.
|
Modifier and Type | Method and Description |
---|---|
static <E0,E1> Tuple2<E0,E1> |
Tuple2.tuple2(E0 f0,
E1 f1)
Returns a new 2-tuple with the supplied values.
|
Copyright © 2018 Hazelcast, Inc.. All rights reserved.