T0
- the type of the stream-0 itemK
- type of the keypublic class WindowGroupAggregateBuilder1<T0,K> extends Object
StageWithKeyAndWindow.aggregateBuilder()
on one of the stages to co-aggregate and refer to that method's Javadoc
for further details.
This object is mainly intended to build a co-aggregation of four or more
contributing stages. For up to three stages, prefer the direct stage.aggregateN(...)
calls because they offer more static type safety.
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(StreamStageWithKey<T,K> stage)
Adds another stage that will contribute its data to the windowed
group-and-aggregate stage being constructed.
|
<R> StreamStage<TimestampedEntry<K,R>> |
build(AggregateOperation<?,R> aggrOp)
Convenience for
build(AggregateOperation, KeyedWindowResultFunction)
which results in a stage that emits TimestampedEntry s. |
<R,OUT> StreamStage<OUT> |
build(AggregateOperation<?,R> aggrOp,
KeyedWindowResultFunction<? super K,? super R,OUT> mapToOutputFn)
Creates and returns a pipeline stage that performs a windowed
cogroup-and-aggregate of the 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 StreamStageWithKey<T,K> stage)
AggregateOperation
that
you'll pass to build()
.@Nonnull public <R,OUT> StreamStage<OUT> build(@Nonnull AggregateOperation<?,R> aggrOp, @Nonnull KeyedWindowResultFunction<? super K,? super R,OUT> mapToOutputFn)
R
- the type of the aggregation resultOUT
- the type of the output itemaggrOp
- the aggregate operation to performmapToOutputFn
- a function that creates the output item from the aggregation resultAggregateOperations
@Nonnull public <R> StreamStage<TimestampedEntry<K,R>> build(@Nonnull AggregateOperation<?,R> aggrOp)
build(AggregateOperation, 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.