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.
|
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 . |
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 . |
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. |
Modifier and Type | Method and Description |
---|---|
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.
|
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<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. |
BatchStage<ItemsByTag> |
AggregateBuilder.build()
Creates and returns a pipeline stage that performs the co-aggregation
of the stages registered with this builder object.
|
Modifier and Type | Method and Description |
---|---|
<R> StreamStage<R> |
StreamHashJoinBuilder.build(BiFunctionEx<T0,ItemsByTag,R> mapToOutputFn)
Builds a new pipeline stage that performs the hash-join operation.
|
<R> BatchStage<R> |
HashJoinBuilder.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.
|
Copyright © 2022 Hazelcast, Inc.. All rights reserved.