Package | Description |
---|---|
com.hazelcast.jet |
The Pipeline API is Jet's high-level API to build and execute
distributed computation jobs.
|
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.
|
Modifier and Type | Method and Description |
---|---|
<E> Tag<E> |
CoGroupBuilder.add(ComputeStage<E> stage,
DistributedFunction<? super E,K> groupKeyFn)
Adds another contributing pipeline stage to the co-grouping operation.
|
<K,E1_IN,E1> |
HashJoinBuilder.add(ComputeStage<E1_IN> stage,
JoinClause<K,E0,E1_IN,E1> joinClause)
Adds another contributing pipeline stage to the hash-join operation.
|
Tag<E0> |
CoGroupBuilder.tag0()
Returns the tag referring to the 0-indexed contributing pipeline
stage, the one from which this builder was obtained.
|
Modifier and Type | Method and Description |
---|---|
default <T> DistributedBiConsumer<? super A,? super T> |
AggregateOperation.accumulateFn(Tag<T> tag)
A primitive that updates the accumulator state to account for a new
item.
|
<T> AggregateOperationBuilder.VarArity<A> |
AggregateOperationBuilder.andAccumulate(Tag<T> tag,
DistributedBiConsumer<? super A,T> accumulateFn)
Registers the supplied
accumulate primitive for the stream tagged
with the supplied tag. |
<T> AggregateOperationBuilder.VarArity<A> |
AggregateOperationBuilder.VarArity.andAccumulate(Tag<T> tag,
DistributedBiConsumer<? super A,T> accumulateFn)
Registers the supplied
accumulate primitive for the stream tagged
with the supplied 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 . |
Modifier and Type | Method and Description |
---|---|
<E> Collection<E> |
BagsByTag.bag(Tag<E> tag)
Retrieves the bag associated with the supplied tag.
|
int |
Tag.compareTo(Tag<?> that) |
<E> Collection<E> |
BagsByTag.ensureBag(Tag<E> tag)
Ensures that there is a mapping from the supplied tag to a bag,
creating an empty one if necessary.
|
<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.
|
Copyright © 2017 Hazelcast, Inc.. All Rights Reserved.