Package | Description |
---|---|
com.hazelcast.jet.core.processor |
Contains static utility classes with factories of Jet processors.
|
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 |
---|---|
static <C,T,K> ProcessorSupplier |
Processors.filterUsingContextAsyncP(ContextFactory<C> contextFactory,
FunctionEx<T,K> extractKeyFn,
BiFunctionEx<? super C,? super T,CompletableFuture<Boolean>> filterAsyncFn)
Asynchronous version of
Processors.filterUsingContextP(com.hazelcast.jet.pipeline.ContextFactory<C>, com.hazelcast.jet.function.BiPredicateEx<? super C, ? super T>) : the filterAsyncFn returns a CompletableFuture<Boolean> instead of
just a boolean . |
static <C,T> ProcessorSupplier |
Processors.filterUsingContextP(ContextFactory<C> contextFactory,
BiPredicateEx<? super C,? super T> filterFn)
Returns a supplier of processors for a vertex that emits the same items
it receives, but only those that pass the given predicate.
|
static <C,T,K,R> ProcessorSupplier |
Processors.flatMapUsingContextAsyncP(ContextFactory<C> contextFactory,
FunctionEx<? super T,? extends K> extractKeyFn,
BiFunctionEx<? super C,? super T,CompletableFuture<Traverser<R>>> flatMapAsyncFn)
Asynchronous version of
Processors.flatMapUsingContextP(com.hazelcast.jet.pipeline.ContextFactory<C>, com.hazelcast.jet.function.BiFunctionEx<? super C, ? super T, ? extends com.hazelcast.jet.Traverser<? extends R>>) : the flatMapAsyncFn returns a CompletableFuture<Traverser<R>>
instead of just a Traverser<R> . |
static <C,T,R> ProcessorSupplier |
Processors.flatMapUsingContextP(ContextFactory<C> contextFactory,
BiFunctionEx<? super C,? super T,? extends Traverser<? extends R>> flatMapFn)
Returns a supplier of processors for a vertex that applies the provided
item-to-traverser mapping function to each received item and emits all
the items from the resulting traverser.
|
static <C,T,K,R> ProcessorSupplier |
Processors.mapUsingContextAsyncP(ContextFactory<C> contextFactory,
FunctionEx<T,K> extractKeyFn,
BiFunctionEx<? super C,? super T,CompletableFuture<R>> mapAsyncFn)
Asynchronous version of
Processors.mapUsingContextP(com.hazelcast.jet.pipeline.ContextFactory<C>, com.hazelcast.jet.function.BiFunctionEx<? super C, ? super T, ? extends R>) : the mapAsyncFn returns a CompletableFuture<R> instead of just
R . |
static <C,T,R> ProcessorSupplier |
Processors.mapUsingContextP(ContextFactory<C> contextFactory,
BiFunctionEx<? super C,? super T,? extends R> mapFn)
Returns a supplier of processors for a vertex which, for each received
item, emits the result of applying the given mapping function to it.
|
Modifier and Type | Method and Description |
---|---|
static <K,V> ContextFactory<IMapJet<K,V>> |
ContextFactories.iMapContext(String mapName)
Returns a factory that provides an
IMapJet as the context. |
static <K,V> ContextFactory<ReplicatedMap<K,V>> |
ContextFactories.replicatedMapContext(String mapName)
Returns a factory that provides a
ReplicatedMap as the context
object. |
ContextFactory<C> |
ContextFactory.toNonCooperative()
Returns a copy of this
ContextFactory with the
isCooperative flag set to false . |
static <C> ContextFactory<C> |
ContextFactory.withCreateFn(FunctionEx<JetInstance,? extends C> createContextFn)
Creates a new
ContextFactory with the given create-function. |
ContextFactory<C> |
ContextFactory.withDestroyFn(ConsumerEx<? super C> destroyFn)
Returns a copy of this
ContextFactory with the destroy-function
replaced with the given function. |
ContextFactory<C> |
ContextFactory.withLocalSharing()
Returns a copy of this
ContextFactory with the
localSharing flag set. |
ContextFactory<C> |
ContextFactory.withMaxPendingCallsPerProcessor(int maxPendingCallsPerProcessor)
Returns a copy of this
ContextFactory with the
maxPendingCallsPerProcessor property set to the given value. |
ContextFactory<C> |
ContextFactory.withUnorderedAsyncResponses()
Returns a copy of this
ContextFactory with the
unorderedAsyncResponses flag set to true. |
Modifier and Type | Method and Description |
---|---|
<C> StreamStage<T> |
StreamStage.filterUsingContext(ContextFactory<C> contextFactory,
BiPredicateEx<? super C,? super T> filterFn) |
<C> GeneralStage<T> |
GeneralStage.filterUsingContext(ContextFactory<C> contextFactory,
BiPredicateEx<? super C,? super T> filterFn)
Attaches a filtering stage which applies the provided predicate function
to each input item to decide whether to pass the item to the output or
to discard it.
|
<C> BatchStage<T> |
BatchStage.filterUsingContext(ContextFactory<C> contextFactory,
BiPredicateEx<? super C,? super T> filterFn) |
<C> StreamStage<T> |
StreamStageWithKey.filterUsingContext(ContextFactory<C> contextFactory,
TriPredicate<? super C,? super K,? super T> filterFn) |
<C> GeneralStage<T> |
GeneralStageWithKey.filterUsingContext(ContextFactory<C> contextFactory,
TriPredicate<? super C,? super K,? super T> filterFn)
Attaches a filtering stage which applies the provided predicate function
to each input item to decide whether to pass the item to the output or
to discard it.
|
<C> BatchStage<T> |
BatchStageWithKey.filterUsingContext(ContextFactory<C> contextFactory,
TriPredicate<? super C,? super K,? super T> filterFn) |
<C> StreamStage<T> |
StreamStage.filterUsingContextAsync(ContextFactory<C> contextFactory,
BiFunctionEx<? super C,? super T,? extends CompletableFuture<Boolean>> filterAsyncFn) |
<C> GeneralStage<T> |
GeneralStage.filterUsingContextAsync(ContextFactory<C> contextFactory,
BiFunctionEx<? super C,? super T,? extends CompletableFuture<Boolean>> filterAsyncFn)
Asynchronous version of
GeneralStage.filterUsingContext(com.hazelcast.jet.pipeline.ContextFactory<C>, com.hazelcast.jet.function.BiPredicateEx<? super C, ? super T>) : the filterAsyncFn returns a CompletableFuture<Boolean> instead of
just a boolean . |
<C> BatchStage<T> |
BatchStage.filterUsingContextAsync(ContextFactory<C> contextFactory,
BiFunctionEx<? super C,? super T,? extends CompletableFuture<Boolean>> filterAsyncFn) |
<C> StreamStage<T> |
StreamStageWithKey.filterUsingContextAsync(ContextFactory<C> contextFactory,
TriFunction<? super C,? super K,? super T,CompletableFuture<Boolean>> filterAsyncFn) |
<C> GeneralStage<T> |
GeneralStageWithKey.filterUsingContextAsync(ContextFactory<C> contextFactory,
TriFunction<? super C,? super K,? super T,CompletableFuture<Boolean>> filterAsyncFn)
Asynchronous version of
GeneralStageWithKey.filterUsingContext(com.hazelcast.jet.pipeline.ContextFactory<C>, com.hazelcast.jet.function.TriPredicate<? super C, ? super K, ? super T>) : the filterAsyncFn returns a CompletableFuture<Boolean> instead of
just a boolean . |
<C> BatchStage<T> |
BatchStageWithKey.filterUsingContextAsync(ContextFactory<C> contextFactory,
TriFunction<? super C,? super K,? super T,CompletableFuture<Boolean>> filterAsyncFn) |
<C,R> StreamStage<R> |
StreamStage.flatMapUsingContext(ContextFactory<C> contextFactory,
BiFunctionEx<? super C,? super T,? extends Traverser<R>> flatMapFn) |
<C,R> GeneralStage<R> |
GeneralStage.flatMapUsingContext(ContextFactory<C> contextFactory,
BiFunctionEx<? super C,? super T,? extends Traverser<R>> flatMapFn)
Attaches a flat-mapping stage which applies the supplied function to
each input item independently and emits all items from the
Traverser it returns as the output items. |
<C,R> BatchStage<R> |
BatchStage.flatMapUsingContext(ContextFactory<C> contextFactory,
BiFunctionEx<? super C,? super T,? extends Traverser<R>> flatMapFn) |
<C,R> StreamStage<R> |
StreamStageWithKey.flatMapUsingContext(ContextFactory<C> contextFactory,
TriFunction<? super C,? super K,? super T,? extends Traverser<? extends R>> flatMapFn) |
<C,R> GeneralStage<R> |
GeneralStageWithKey.flatMapUsingContext(ContextFactory<C> contextFactory,
TriFunction<? super C,? super K,? super T,? extends Traverser<? extends R>> flatMapFn)
Attaches a flat-mapping stage which applies the supplied function to
each input item independently and emits all the items from the
Traverser it returns as the output items. |
<C,R> BatchStage<R> |
BatchStageWithKey.flatMapUsingContext(ContextFactory<C> contextFactory,
TriFunction<? super C,? super K,? super T,? extends Traverser<? extends R>> flatMapFn) |
<C,R> StreamStage<R> |
StreamStage.flatMapUsingContextAsync(ContextFactory<C> contextFactory,
BiFunctionEx<? super C,? super T,? extends CompletableFuture<Traverser<R>>> flatMapAsyncFn) |
<C,R> GeneralStage<R> |
GeneralStage.flatMapUsingContextAsync(ContextFactory<C> contextFactory,
BiFunctionEx<? super C,? super T,? extends CompletableFuture<Traverser<R>>> flatMapAsyncFn)
Asynchronous version of
GeneralStage.flatMapUsingContext(com.hazelcast.jet.pipeline.ContextFactory<C>, com.hazelcast.jet.function.BiFunctionEx<? super C, ? super T, ? extends com.hazelcast.jet.Traverser<R>>) : the flatMapAsyncFn returns a CompletableFuture<Traverser<R>>
instead of just Traverser<R> . |
<C,R> BatchStage<R> |
BatchStage.flatMapUsingContextAsync(ContextFactory<C> contextFactory,
BiFunctionEx<? super C,? super T,? extends CompletableFuture<Traverser<R>>> flatMapAsyncFn) |
<C,R> StreamStage<R> |
StreamStageWithKey.flatMapUsingContextAsync(ContextFactory<C> contextFactory,
TriFunction<? super C,? super K,? super T,CompletableFuture<Traverser<R>>> flatMapAsyncFn) |
<C,R> GeneralStage<R> |
GeneralStageWithKey.flatMapUsingContextAsync(ContextFactory<C> contextFactory,
TriFunction<? super C,? super K,? super T,CompletableFuture<Traverser<R>>> flatMapAsyncFn)
Asynchronous version of
GeneralStageWithKey.flatMapUsingContext(com.hazelcast.jet.pipeline.ContextFactory<C>, com.hazelcast.jet.function.TriFunction<? super C, ? super K, ? super T, ? extends com.hazelcast.jet.Traverser<? extends R>>) : the flatMapAsyncFn returns a CompletableFuture<Traverser<R>>
instead of just Traverser<R> . |
<C,R> BatchStage<R> |
BatchStageWithKey.flatMapUsingContextAsync(ContextFactory<C> contextFactory,
TriFunction<? super C,? super K,? super T,CompletableFuture<Traverser<R>>> flatMapAsyncFn) |
<C,R> StreamStage<R> |
StreamStage.mapUsingContext(ContextFactory<C> contextFactory,
BiFunctionEx<? super C,? super T,? extends R> mapFn) |
<C,R> GeneralStage<R> |
GeneralStage.mapUsingContext(ContextFactory<C> contextFactory,
BiFunctionEx<? super C,? super T,? extends R> mapFn)
Attaches a mapping stage which applies the supplied function to each
input item independently and emits the function's result as the output
item.
|
<C,R> BatchStage<R> |
BatchStage.mapUsingContext(ContextFactory<C> contextFactory,
BiFunctionEx<? super C,? super T,? extends R> mapFn) |
<C,R> StreamStage<R> |
StreamStageWithKey.mapUsingContext(ContextFactory<C> contextFactory,
TriFunction<? super C,? super K,? super T,? extends R> mapFn) |
<C,R> GeneralStage<R> |
GeneralStageWithKey.mapUsingContext(ContextFactory<C> contextFactory,
TriFunction<? super C,? super K,? super T,? extends R> mapFn)
Attaches a mapping stage which applies the given function to each input
item independently and emits the function's result as the output item.
|
<C,R> BatchStage<R> |
BatchStageWithKey.mapUsingContext(ContextFactory<C> contextFactory,
TriFunction<? super C,? super K,? super T,? extends R> mapFn) |
<C,R> StreamStage<R> |
StreamStage.mapUsingContextAsync(ContextFactory<C> contextFactory,
BiFunctionEx<? super C,? super T,? extends CompletableFuture<R>> mapAsyncFn) |
<C,R> GeneralStage<R> |
GeneralStage.mapUsingContextAsync(ContextFactory<C> contextFactory,
BiFunctionEx<? super C,? super T,? extends CompletableFuture<R>> mapAsyncFn)
Asynchronous version of
GeneralStage.mapUsingContext(com.hazelcast.jet.pipeline.ContextFactory<C>, com.hazelcast.jet.function.BiFunctionEx<? super C, ? super T, ? extends R>) : the mapAsyncFn
returns a CompletableFuture<R> instead of just R . |
<C,R> BatchStage<R> |
BatchStage.mapUsingContextAsync(ContextFactory<C> contextFactory,
BiFunctionEx<? super C,? super T,? extends CompletableFuture<R>> mapAsyncFn) |
<C,R> StreamStage<R> |
StreamStageWithKey.mapUsingContextAsync(ContextFactory<C> contextFactory,
TriFunction<? super C,? super K,? super T,CompletableFuture<R>> mapAsyncFn) |
<C,R> GeneralStage<R> |
GeneralStageWithKey.mapUsingContextAsync(ContextFactory<C> contextFactory,
TriFunction<? super C,? super K,? super T,CompletableFuture<R>> mapAsyncFn)
Asynchronous version of
GeneralStageWithKey.mapUsingContext(com.hazelcast.jet.pipeline.ContextFactory<C>, com.hazelcast.jet.function.TriFunction<? super C, ? super K, ? super T, ? extends R>) : the mapAsyncFn
returns a CompletableFuture<R> instead of just R . |
<C,R> BatchStage<R> |
BatchStageWithKey.mapUsingContextAsync(ContextFactory<C> contextFactory,
TriFunction<? super C,? super K,? super T,CompletableFuture<R>> mapAsyncFn) |
Copyright © 2019 Hazelcast, Inc.. All rights reserved.