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 and 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 and 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 and 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 and 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 and Description
<T> Tag<T>	AggregateBuilder1.add(BatchStage<T> stage) Adds another stage that will contribute its data to the aggregate operation to be performed.
<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.
<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> 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>	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.
<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>	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.
<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.
<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.
<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<T0>	GroupAggregateBuilder1.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<T0>	WindowGroupAggregateBuilder1.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<R0>	AggregateBuilder.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.