Package | Description |
---|---|
com.hazelcast.jet.aggregate |
Contains
AggregateOperation and several its 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 |
---|---|
AggregateOperation1<T,Object[],ItemsByTag> |
AllOfAggregationBuilder.build()
Builds and returns the composite
AggregateOperation1 . |
Modifier and Type | Method and Description |
---|---|
<R> AggregateOperation1<T,Object[],R> |
AllOfAggregationBuilder.build(DistributedFunction<ItemsByTag,R> finishFn)
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 |
---|---|
<R> StreamStage<R> |
StreamHashJoinBuilder.build(DistributedBiFunction<T0,ItemsByTag,R> mapToOutputFn)
Builds a new pipeline stage that performs the hash-join operation.
|
<R> BatchStage<R> |
HashJoinBuilder.build(DistributedBiFunction<T0,ItemsByTag,R> mapToOutputFn)
Builds a new pipeline stage that performs the hash-join operation.
|
Copyright © 2018 Hazelcast, Inc.. All rights reserved.