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.pipeline |
The Pipeline API is Jet's high-level API to build and execute
distributed computation jobs.
|
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. |
static <T0,T1> AggregateOperation2<T0,T1,TwoBags<T0,T1>,TwoBags<T0,T1>> |
AggregateOperations.toTwoBags()
Returns an
AggregateOperation that accumulates the items from
exactly two inputs into TwoBags : items from inputN are
accumulated into bagN. |
<T0_NEW> AggregateOperation2<T0_NEW,T1,A,R> |
AggregateOperation2.withAccumulateFn0(DistributedBiConsumer<? super A,? super T0_NEW> newAccFn0)
Returns a copy of this aggregate operation, but with the
accumulate primitive at index 0 replaced with the one supplied here. |
<T1_NEW> AggregateOperation2<T0,T1_NEW,A,R> |
AggregateOperation2.withAccumulateFn1(DistributedBiConsumer<? super A,? super T1_NEW> newAccFn1)
Returns a copy of this aggregate operation, but with the
accumulate primitive at index 1 replaced with the one supplied here. |
<R1> AggregateOperation2<T0,T1,A,R1> |
AggregateOperation2.withFinishFn(DistributedFunction<? super A,R1> finishFn) |
Modifier and Type | Method and Description |
---|---|
<T1,A,R> BatchStage<R> |
BatchStage.aggregate2(BatchStage<T1> stage1,
AggregateOperation2<? super T,? super T1,A,? extends R> aggrOp)
Attaches to this stage a stage that performs the given aggregate
operation over all the items it receives from both this stage and
stage1 you supply. |
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,A,R> StreamStage<TimestampedItem<R>> |
StageWithWindow.aggregate2(StreamStage<T1> stage1,
AggregateOperation2<? super T,? super T1,A,R> aggrOp)
Attaches to this stage a stage that performs the given aggregate
operation over all the items that belong to the same window.
|
<T1,A,R,OUT> |
StageWithWindow.aggregate2(StreamStage<T1> stage1,
AggregateOperation2<? super T,? super T1,A,R> aggrOp,
WindowResultFunction<? super R,? extends OUT> mapToOutputFn)
Attaches to this stage a stage that performs the given aggregate
operation over all the items that belong to the same window.
|
<T1,A,R> StreamStage<TimestampedEntry<K,R>> |
StageWithGroupingAndWindow.aggregate2(StreamStageWithGrouping<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> |
StageWithGroupingAndWindow.aggregate2(StreamStageWithGrouping<T1,? extends K> stage1,
AggregateOperation2<? super T,? super T1,A,R> aggrOp,
KeyedWindowResultFunction<? 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. |
Copyright © 2018 Hazelcast, Inc.. All rights reserved.