Package com.hazelcast.jet.pipeline

Class WindowAggregateBuilder1<T0>

  • Type Parameters:
    T0 - the type of the stream-0 item
    public class WindowAggregateBuilder1<T0>
extends java.lang.Object
    Offers a step-by-step fluent API to build a pipeline stage that performs a windowed co-aggregation of the data from several input stages. To obtain it, call 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.

    Since:
    Jet 3.0

    • Method Summary

      All Methods Instance Methods Concrete Methods 
      Modifier and Type Method Description
      <E> Tag<E> add​(StreamStage<E> stage)
      Adds another stage that will contribute its data to the aggregate operation to be performed.
      <A,​R>
      StreamStage<WindowResult<R>>      		 build​(AggregateOperation<A,​R> aggrOp)
      Creates and returns a pipeline stage that performs a windowed co-aggregation 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.

      • Methods inherited from class java.lang.Object

        clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

    • Method Detail

      • tag0

        @Nonnull
public Tag<T0> tag0()
        Returns the tag corresponding to the pipeline stage this builder was obtained from. Use this tag to refer to this stage when building the AggregateOperation that you'll pass to build(aggrOp).

      • add

        @Nonnull
public <E> Tag<E> add​(StreamStage<E> stage)
        Adds another stage that will contribute its data to the aggregate operation to be performed. Returns the tag you'll use to refer to this stage when building the AggregateOperation that you'll pass to build().

      • build

        @Nonnull
public <A,​R> StreamStage<WindowResult<R>> build​(@Nonnull
                                                      AggregateOperation<A,​R> aggrOp)
        Creates and returns a pipeline stage that performs a windowed co-aggregation of the pipeline stages registered with this builder object. The tags you register with the aggregate operation must match the tags you registered with this builder.
        Type Parameters:
        R - the type of the aggregation result
        Parameters:
        aggrOp - the aggregate operation to perform
        Returns:
        a new stage representing the co-aggregation