R0
- type of the aggregation result for stream-0public class AggregateBuilder<R0> extends Object
BatchStage.aggregateBuilder()
on the first stage you are co-aggregating
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,R> Tag<R> |
add(BatchStage<T> stage,
AggregateOperation1<? super T,?,? extends R> aggrOp)
Adds another stage that will contribute its data to the aggregate
operation to be performed.
|
BatchStage<ItemsByTag> |
build()
Creates and returns a pipeline stage that performs the co-aggregation
of the stages registered with this builder object.
|
<R> BatchStage<R> |
build(DistributedFunction<? super ItemsByTag,? extends R> finishFn)
Creates and returns a pipeline stage that performs the co-aggregation
of the stages registered with this builder object.
|
Tag<R0> |
tag0()
Returns the tag corresponding to the pipeline stage this builder
was obtained from.
|
@Nonnull public Tag<R0> tag0()
AggregateOperation
that you'll pass to build(aggrOp)
.@Nonnull public <T,R> Tag<R> add(@Nonnull BatchStage<T> stage, @Nonnull AggregateOperation1<? super T,?,? extends R> aggrOp)
AggregateOperation
that you'll pass to
build()
.@Nonnull public <R> BatchStage<R> build(@Nonnull DistributedFunction<? super ItemsByTag,? extends R> finishFn)
ItemsByTag
and the finishFn
you supply
transforms it to the final result to emit. Use the tags you got from
this builder in the implementation of finishFn
to access the
results.R
- the output item typefinishFn
- the finishing function for the composite aggregate operation@Nonnull public BatchStage<ItemsByTag> build()
ItemsByTag
. Use the tags you got from
this builder to access the results.Copyright © 2018 Hazelcast, Inc.. All rights reserved.