K
- type of the keyR0
- type of the aggregation result for stream-0public 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 here
.
Modifier and Type | Method and Description |
---|---|
<T,R> Tag<R> |
add(StreamStageWithKey<T,K> stage,
AggregateOperation1<? super T,?,? extends R> aggrOp)
Adds another stage that will contribute its data to the windowed
group-and-aggregate stage being constructed.
|
StreamStage<TimestampedEntry<K,ItemsByTag>> |
build()
Convenience for
build(KeyedWindowResultFunction) which results
in a stage that emits TimestampedEntry s. |
<OUT> StreamStage<OUT> |
build(KeyedWindowResultFunction<? super K,ItemsByTag,OUT> mapToOutputFn)
Creates and returns a pipeline stage that performs a windowed
cogroup-and-aggregate operation on 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 StreamStageWithKey<T,K> stage, @Nonnull AggregateOperation1<? super T,?,? extends R> aggrOp)
AggregateOperation
that
you'll pass to build()
.@Nonnull public <OUT> StreamStage<OUT> build(@Nonnull KeyedWindowResultFunction<? super K,ItemsByTag,OUT> mapToOutputFn)
ItemsByTag
and the
mapToOutputFn
you supply transforms it to the final result to
emit. Use the tags you got from this builder in the implementation of
mapToOutputFn
to access the results.OUT
- the output item typemapToOutputFn
- function that transforms the aggregation result into the output item@Nonnull public StreamStage<TimestampedEntry<K,ItemsByTag>> build()
build(KeyedWindowResultFunction)
which results
in a stage that emits TimestampedEntry
s. The timestamp of the
entry corresponds to the timestamp of the window's end.Copyright © 2018 Hazelcast, Inc.. All rights reserved.