## Uses of Class
com.hazelcast.jet.pipeline.ContextFactory

- Packages that use ContextFactory
  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.

- - ### Uses of ContextFactory in com.hazelcast.jet.core.processor

    Methods in com.hazelcast.jet.core.processor with parameters of type ContextFactory
    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.

  - ### Uses of ContextFactory in com.hazelcast.jet.pipeline

    Methods in com.hazelcast.jet.pipeline that return ContextFactory
    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.

    Methods in com.hazelcast.jet.pipeline with parameters of type ContextFactory
    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. All rights reserved.