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

Packages that use ItemsByTag

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 ItemsByTag in com.hazelcast.jet.aggregate

Methods in com.hazelcast.jet.aggregate that return types with arguments of type ItemsByTag

Modifier and Type	Method and Description
AggregateOperation<Object[],ItemsByTag>	CoAggregateOperationBuilder.build() Builds and returns the AggregateOperation.
AggregateOperation1<T,Object[],ItemsByTag>	AllOfAggregationBuilder.build() Builds and returns the composite AggregateOperation1.

Method parameters in com.hazelcast.jet.aggregate with type arguments of type ItemsByTag

Modifier and Type	Method and Description
<R> AggregateOperation<Object[],R>	CoAggregateOperationBuilder.build(FunctionEx<? super ItemsByTag,? extends R> exportFinishFn) Builds and returns the multi-input AggregateOperation.
<R> AggregateOperation1<T,Object[],R>	AllOfAggregationBuilder.build(FunctionEx<ItemsByTag,R> exportFinishFn) Builds and returns the composite AggregateOperation1.

Uses of ItemsByTag in com.hazelcast.jet.datamodel

Methods in com.hazelcast.jet.datamodel that return ItemsByTag

Modifier and Type	Method and Description
static ItemsByTag	ItemsByTag.itemsByTag(Object... tagsAndVals) Accepts an argument list of alternating tags and values, interprets them as a list of tag-value pairs, and returns an ItemsByTag populated with these pairs.

Uses of ItemsByTag in com.hazelcast.jet.pipeline

Methods in com.hazelcast.jet.pipeline that return types with arguments of type ItemsByTag

Modifier and Type	Method and Description
BatchStage<Map.Entry<K,ItemsByTag>>	GroupAggregateBuilder.build() Creates and returns a pipeline stage that performs the co-aggregation of the stages registered with this builder object and emits a Map.Entry(key, resultsByTag) for each distinct key.
StreamStage<WindowResult<ItemsByTag>>	WindowAggregateBuilder.build() Creates and returns a pipeline stage that performs a windowed co-aggregation of the stages registered with this builder object.
BatchStage<ItemsByTag>	AggregateBuilder.build() Creates and returns a pipeline stage that performs the co-aggregation of the stages registered with this builder object.
StreamStage<KeyedWindowResult<K,ItemsByTag>>	WindowGroupAggregateBuilder.build() Creates and returns a pipeline stage that performs a windowed cogroup-and-aggregate operation on the stages registered with this builder object.

Method parameters in com.hazelcast.jet.pipeline with type arguments of type ItemsByTag

Modifier and Type	Method and Description
<R> BatchStage<R>	HashJoinBuilder.build(BiFunctionEx<T0,ItemsByTag,R> mapToOutputFn) Builds a new pipeline stage that performs the hash-join operation.
<R> StreamStage<R>	StreamHashJoinBuilder.build(BiFunctionEx<T0,ItemsByTag,R> mapToOutputFn) Builds a new pipeline stage that performs the hash-join operation.
<R> BatchStage<R>	AggregateBuilder.build(FunctionEx<? super ItemsByTag,? extends R> finishFn) Creates and returns a pipeline stage that performs the co-aggregation of the stages registered with this builder object.