Uses of Class
com.hazelcast.jet.datamodel.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 Description AggregateOperation1<T,Object[],ItemsByTag>
AllOfAggregationBuilder. build()
Builds and returns the compositeAggregateOperation1
.AggregateOperation<Object[],ItemsByTag>
CoAggregateOperationBuilder. build()
Builds and returns theAggregateOperation
.Method parameters in com.hazelcast.jet.aggregate with type arguments of type ItemsByTag Modifier and Type Method Description <R> AggregateOperation1<T,Object[],R>
AllOfAggregationBuilder. build(FunctionEx<ItemsByTag,R> exportFinishFn)
Builds and returns the compositeAggregateOperation1
.<R> AggregateOperation<Object[],R>
CoAggregateOperationBuilder. build(FunctionEx<? super ItemsByTag,? extends R> exportFinishFn)
Builds and returns the multi-inputAggregateOperation
. -
Uses of ItemsByTag in com.hazelcast.jet.datamodel
Methods in com.hazelcast.jet.datamodel that return ItemsByTag Modifier and Type Method 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 anItemsByTag
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 Description BatchStage<ItemsByTag>
AggregateBuilder. build()
Creates and returns a pipeline stage that performs the co-aggregation of the stages registered with this builder object.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 aMap.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.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 Description <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.<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.