T0
- type of the stream-0 itemK
- type of the grouping keypublic class GroupAggregateBuilder1<T0,K> extends Object
BatchStageWithKey.aggregateBuilder()
on one of the stages to co-group
and refer to that method's Javadoc for further details.
Note: this is not a builder of AggregateOperation
. If that' s what you are looking for, go here
.
Modifier and Type | Method and Description |
---|---|
<T> Tag<T> |
add(BatchStageWithKey<T,K> stage)
Adds another stage that will contribute its data to the aggregate
operation to be performed.
|
<R> BatchStage<Map.Entry<K,R>> |
build(AggregateOperation<?,R> aggrOp)
Convenience for
build(aggrOp, mapToOutputFn) which emits Map.Entry s as output. |
<R,OUT> BatchStage<OUT> |
build(AggregateOperation<?,R> aggrOp,
DistributedBiFunction<? super K,? super R,OUT> mapToOutputFn)
Creates and returns a pipeline stage that performs the
co-grouping and aggregation of pipeline stages registered with this
builder object.
|
Tag<T0> |
tag0()
Returns the tag corresponding to the pipeline stage this builder
was obtained from.
|
@Nonnull public Tag<T0> tag0()
AggregateOperation
that you'll pass to build(aggrOp)
.@Nonnull public <T> Tag<T> add(@Nonnull BatchStageWithKey<T,K> stage)
AggregateOperation
that you'll pass to
build()
.@Nonnull public <R,OUT> BatchStage<OUT> build(@Nonnull AggregateOperation<?,R> aggrOp, @Nonnull DistributedBiFunction<? super K,? super R,OUT> mapToOutputFn)
R
- the type of the output itemaggrOp
- the aggregate operation to perform@Nonnull public <R> BatchStage<Map.Entry<K,R>> build(@Nonnull AggregateOperation<?,R> aggrOp)
build(aggrOp, mapToOutputFn)
which emits Map.Entry
s as output.R
- the type of the aggregation resultaggrOp
- the aggregate operation to perform.Copyright © 2018 Hazelcast, Inc.. All rights reserved.