K- type of the key
R0- type of the aggregation result for stream-0
public class WindowGroupAggregateBuilder<K,R0> extends Object
StageWithKeyAndWindow.aggregateBuilder()on one of the stages to co-aggregate 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
|Modifier and Type||Method and Description|
Adds another stage that will contribute its data to the windowed group-and-aggregate stage being constructed.
Creates and returns a pipeline stage that performs a windowed cogroup-and-aggregate operation on the stages registered with this builder object.
Returns the tag corresponding to the pipeline stage this builder was obtained from.
@Nonnull public <T,R> Tag<R> add(@Nonnull StreamStageWithKey<T,K> stage, @Nonnull AggregateOperation1<? super T,?,? extends R> aggrOp)
AggregateOperationthat you'll pass to
@Nonnull public StreamStage<KeyedWindowResult<K,ItemsByTag>> build()
ItemsByTag. Use the tags you got from this builder to access the results.
Copyright © 2022 Hazelcast, Inc.. All rights reserved.