Uses of Class
com.hazelcast.jet.datamodel.Tag

Packages that use Tag
Package
Description
com.hazelcast.jet.aggregate
Contains AggregateOperation and its several variants, as well as a builder object for the aggregate operations.
com.hazelcast.jet.datamodel
Generic data containers used by the Pipeline API.
com.hazelcast.jet.pipeline
The Pipeline API is Jet's high-level API to build and execute distributed computation jobs.

  • Uses of Tag in com.hazelcast.jet.aggregate

    Methods in com.hazelcast.jet.aggregate that return Tag
    Modifier and Type
    Method
    Description
    <R> Tag<R>
    AllOfAggregationBuilder.add(AggregateOperation1<? super T,?,R> operation)
    Adds the supplied aggregate operation to the composite.
    <T, R> Tag<R>
    CoAggregateOperationBuilder.add(Tag<T> tag, AggregateOperation1<? super T,?,? extends R> operation)
    Registers the given aggregate operation with the tag corresponding to an input to the co-aggregating operation being built.
    Methods in com.hazelcast.jet.aggregate with parameters of type Tag
    Modifier and Type
    Method
    Description
    default <T> BiConsumerEx<? super A,? super T>
    AggregateOperation.accumulateFn(Tag<T> tag)
    A primitive that updates the accumulator state to account for a new item.
    <T, R> Tag<R>
    CoAggregateOperationBuilder.add(Tag<T> tag, AggregateOperation1<? super T,?,? extends R> operation)
    Registers the given aggregate operation with the tag corresponding to an input to the co-aggregating operation being built.
    <T> AggregateOperationBuilder.VarArity<A,Void>
    AggregateOperationBuilder.andAccumulate(Tag<T> tag, BiConsumerEx<? super A,? super T> accumulateFn)
    Registers the accumulate primitive for the stream tagged with the supplied tag.
    <T> AggregateOperationBuilder.VarArity<A,R>
    AggregateOperationBuilder.VarArity.andAccumulate(Tag<T> tag, BiConsumerEx<? super A,T> accumulateFn)
    Registers the accumulate primitive for the stream tagged with the supplied tag.

  • Uses of Tag in com.hazelcast.jet.datamodel

    Methods in com.hazelcast.jet.datamodel that return Tag
    Modifier and Type
    Method
    Description
    static <T> Tag<T>
    Tag.tag(int index)
    Returns a tag object associated with the specified index.
    static <T> Tag<T>
    Tag.tag0()
    Returns the tag constant TAG_0.
    static <T> Tag<T>
    Tag.tag1()
    Returns the tag constant TAG_1.
    static <T> Tag<T>
    Tag.tag2()
    Returns the tag constant TAG_2.
    Methods in com.hazelcast.jet.datamodel with parameters of type Tag
    Modifier and Type
    Method
    Description
    int
    Tag.compareTo(Tag<?> that)
     
    <E> E
    ItemsByTag.get(Tag<E> tag)
    Retrieves the value associated with the supplied tag and throws an exception if there is none.
    <E> void
    ItemsByTag.put(Tag<E> tag, E value)
    Associates the supplied value with the supplied tag.

  • Uses of Tag in com.hazelcast.jet.pipeline

    Methods in com.hazelcast.jet.pipeline that return Tag
    Modifier and Type
    Method
    Description
    <T, R> Tag<R>
    AggregateBuilder.add(BatchStage<T> stage, AggregateOperation1<? super T,?,? extends R> aggrOp)
    Adds another stage that will contribute its data to the aggregate operation to be performed.
    <T> Tag<T>
    AggregateBuilder1.add(BatchStage<T> stage)
    Adds another stage that will contribute its data to the aggregate operation to be performed.
    <K, T1_IN, T1>
    Tag<T1>
    GeneralHashJoinBuilder.add(BatchStage<T1_IN> stage, JoinClause<K,T0,T1_IN,T1> joinClause)
    Adds another contributing pipeline stage to the hash-join operation.
    <T, R> Tag<R>
    GroupAggregateBuilder.add(BatchStageWithKey<T,K> stage, AggregateOperation1<? super T,?,? extends R> aggrOp)
    Adds another stage that will contribute its data to the aggregate operation to be performed.
    <T> Tag<T>
    GroupAggregateBuilder1.add(BatchStageWithKey<T,K> stage)
    Adds another stage that will contribute its data to the aggregate operation to be performed.
    <T, R> Tag<R>
    WindowAggregateBuilder.add(StreamStage<T> stage, AggregateOperation1<? super T,?,? extends R> aggrOp)
    Adds another stage that will contribute its data to the aggregate operation to be performed.
    <E> Tag<E>
    WindowAggregateBuilder1.add(StreamStage<E> stage)
    Adds another stage that will contribute its data to the aggregate operation to be performed.
    <T, R> Tag<R>
    WindowGroupAggregateBuilder.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.
    <T> Tag<T>
    WindowGroupAggregateBuilder1.add(StreamStageWithKey<T,K> stage)
    Adds another stage that will contribute its data to the windowed group-and-aggregate stage being constructed.
    <K, T1_IN, T1>
    Tag<T1>
    GeneralHashJoinBuilder.addInner(BatchStage<T1_IN> stage, JoinClause<K,T0,T1_IN,T1> joinClause)
    Adds another contributing pipeline stage to the hash-join operation.
    Tag<R0>
    AggregateBuilder.tag0()
    Returns the tag corresponding to the pipeline stage this builder was obtained from.
    Tag<T0>
    AggregateBuilder1.tag0()
    Returns the tag corresponding to the pipeline stage this builder was obtained from.
    Tag<R0>
    GroupAggregateBuilder.tag0()
    Returns the tag corresponding to the pipeline stage this builder was obtained from.
    Tag<T0>
    GroupAggregateBuilder1.tag0()
    Returns the tag corresponding to the pipeline stage this builder was obtained from.
    Tag<R0>
    WindowAggregateBuilder.tag0()
    Returns the tag corresponding to the pipeline stage this builder was obtained from.
    Tag<T0>
    WindowAggregateBuilder1.tag0()
    Returns the tag corresponding to the pipeline stage this builder was obtained from.
    Tag<R0>
    WindowGroupAggregateBuilder.tag0()
    Returns the tag corresponding to the pipeline stage this builder was obtained from.
    Tag<T0>
    WindowGroupAggregateBuilder1.tag0()
    Returns the tag corresponding to the pipeline stage this builder was obtained from.