T0
- the type of the stream-0 itempublic class WindowAggregateBuilder1<T0> extends Object
StageWithWindow.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 |
---|---|
<E> Tag<E> |
add(StreamStage<E> stage)
Adds another stage that will contribute its data to the aggregate
operation to be performed.
|
<R,OUT> StreamStage<OUT> |
build(AggregateOperation<?,R> aggrOp,
WindowResultFunction<? super R,? extends OUT> mapToOutputFn)
Creates and returns a pipeline stage that performs a windowed
co-aggregation of the pipeline stages registered with this builder
object.
|
<A,R> StreamStage<TimestampedItem<R>> |
build(AggregateOperation<A,R> aggrOp)
Convenience for
build(aggrOp, mapToOutputFn) which emits TimestampedItem s as output. |
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 <E> Tag<E> add(StreamStage<E> stage)
AggregateOperation
that you'll pass to
build()
.@Nonnull public <R,OUT> StreamStage<OUT> build(@Nonnull AggregateOperation<?,R> aggrOp, @Nonnull WindowResultFunction<? super R,? extends 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 result@Nonnull public <A,R> StreamStage<TimestampedItem<R>> build(@Nonnull AggregateOperation<A,R> aggrOp)
build(aggrOp, mapToOutputFn)
which emits TimestampedItem
s as output.
The timestamp corresponds to the window's end.A
- the type of items in the pipeline stage this builder was obtained fromR
- the type of the aggregation resultaggrOp
- the aggregate operation to perform.Copyright © 2018 Hazelcast, Inc.. All rights reserved.