Uses of Class
com.hazelcast.jet.pipeline.ServiceFactory

Packages that use ServiceFactory

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.
com.hazelcast.jet.spring	Spring integration for Hazelcast Jet

Uses of ServiceFactory in com.hazelcast.jet.core.processor

Methods in com.hazelcast.jet.core.processor with parameters of type ServiceFactory

Modifier and Type	Method	Description
static <C, S, T> ProcessorSupplier	Processors.filterUsingServiceP(ServiceFactory<C,S> serviceFactory, BiPredicateEx<? super S,? 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, S, T, R> ProcessorSupplier	Processors.flatMapUsingServiceP(ServiceFactory<C,S> serviceFactory, BiFunctionEx<? super S,? super T,? extends Traverser<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, S, T, K, R> ProcessorSupplier	Processors.mapUsingServiceAsyncP(ServiceFactory<C,S> serviceFactory, int maxConcurrentOps, boolean preserveOrder, FunctionEx<T,K> extractKeyFn, BiFunctionEx<? super S,? super T,CompletableFuture<R>> mapAsyncFn)	Asynchronous version of Processors.mapUsingServiceP(com.hazelcast.jet.pipeline.ServiceFactory<C, S>, com.hazelcast.function.BiFunctionEx<? super S, ? super T, ? extends R>): the mapAsyncFn returns a CompletableFuture<R> instead of just R.
static <C, S, T, R> ProcessorSupplier	Processors.mapUsingServiceP(ServiceFactory<C,S> serviceFactory, BiFunctionEx<? super S,? 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 ServiceFactory in com.hazelcast.jet.pipeline

Methods in com.hazelcast.jet.pipeline that return ServiceFactory

Modifier and Type	Method	Description
protected ServiceFactory<C,S>	ServiceFactory.clone()
static <K, V> ServiceFactory<?,IMap<K,V>>	ServiceFactories.iMapService(String mapName)	Returns a factory that provides an IMap as the service.
static <S> ServiceFactory<?,S>	ServiceFactories.nonSharedService(FunctionEx<? super Processor.Context,? extends S> createServiceFn)	A variant of nonSharedService(createFn, destroyFn) with a no-op destroyFn.
static <S> ServiceFactory<?,S>	ServiceFactories.nonSharedService(FunctionEx<? super Processor.Context,? extends S> createServiceFn, ConsumerEx<? super S> destroyServiceFn)	Returns a ServiceFactory which creates a separate service instance for each parallel Jet processor.
static <K, V> ServiceFactory<?,ReplicatedMap<K,V>>	ServiceFactories.replicatedMapService(String mapName)	Returns a factory that provides a ReplicatedMap as the service object.
static <S> ServiceFactory<?,S>	ServiceFactories.sharedService(FunctionEx<? super ProcessorSupplier.Context,S> createServiceFn)	A variant of sharedService(createFn, destroyFn) with a no-op destroyFn.
static <S> ServiceFactory<?,S>	ServiceFactories.sharedService(FunctionEx<? super ProcessorSupplier.Context,S> createServiceFn, ConsumerEx<S> destroyServiceFn)	Returns a ServiceFactory which will provide a single shared service object per cluster member.
ServiceFactory<C,S>	ServiceFactory.toNonCooperative()	Returns a copy of this ServiceFactory with the isCooperative flag set to false.
ServiceFactory<C,S>	ServiceFactory.withAttachedDirectory(String id, File directory)	Attaches a directory to this service factory under the given ID.
ServiceFactory<C,S>	ServiceFactory.withAttachedFile(String id, File file)	Attaches a file to this service factory under the given ID.
static <C> ServiceFactory<C,Void>	ServiceFactory.withCreateContextFn(FunctionEx<? super ProcessorSupplier.Context,? extends C> createContextFn)	Creates a new ServiceFactory with the given function that creates the shared context object.
<S_NEW> ServiceFactory<C,S_NEW>	ServiceFactory.withCreateServiceFn(BiFunctionEx<? super Processor.Context,? super C,? extends S_NEW> createServiceFn)	Returns a copy of this ServiceFactory with the given createService function.
ServiceFactory<C,S>	ServiceFactory.withDestroyContextFn(ConsumerEx<? super C> destroyContextFn)	Returns a copy of this ServiceFactory with the destroyContext function replaced with the given function.
ServiceFactory<C,S>	ServiceFactory.withDestroyServiceFn(ConsumerEx<? super S> destroyServiceFn)	Returns a copy of this ServiceFactory with the destroyService function replaced with the given function.
ServiceFactory<C,S>	ServiceFactory.withoutAttachedFiles()	Returns a copy of this ServiceFactory with any attached files removed.

Methods in com.hazelcast.jet.pipeline with parameters of type ServiceFactory

Modifier and Type	Method	Description
<S> BatchStage<T>	BatchStage.filterUsingService(ServiceFactory<?,S> serviceFactory, BiPredicateEx<? super S,? super T> filterFn)
<S> BatchStage<T>	BatchStageWithKey.filterUsingService(ServiceFactory<?,S> serviceFactory, TriPredicate<? super S,? super K,? super T> filterFn)
<S> GeneralStage<T>	GeneralStage.filterUsingService(ServiceFactory<?,S> serviceFactory, BiPredicateEx<? super S,? 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.
<S> GeneralStage<T>	GeneralStageWithKey.filterUsingService(ServiceFactory<?,S> serviceFactory, TriPredicate<? super S,? 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.
<S> StreamStage<T>	StreamStage.filterUsingService(ServiceFactory<?,S> serviceFactory, BiPredicateEx<? super S,? super T> filterFn)
<S> StreamStage<T>	StreamStageWithKey.filterUsingService(ServiceFactory<?,S> serviceFactory, TriPredicate<? super S,? super K,? super T> filterFn)
<S, R> BatchStage<R>	BatchStage.flatMapUsingService(ServiceFactory<?,S> serviceFactory, BiFunctionEx<? super S,? super T,? extends Traverser<R>> flatMapFn)
<S, R> BatchStage<R>	BatchStageWithKey.flatMapUsingService(ServiceFactory<?,S> serviceFactory, TriFunction<? super S,? super K,? super T,? extends Traverser<R>> flatMapFn)
<S, R> GeneralStage<R>	GeneralStage.flatMapUsingService(ServiceFactory<?,S> serviceFactory, BiFunctionEx<? super S,? 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.
<S, R> GeneralStage<R>	GeneralStageWithKey.flatMapUsingService(ServiceFactory<?,S> serviceFactory, TriFunction<? super S,? super K,? super T,? extends Traverser<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.
<S, R> StreamStage<R>	StreamStage.flatMapUsingService(ServiceFactory<?,S> serviceFactory, BiFunctionEx<? super S,? super T,? extends Traverser<R>> flatMapFn)
<S, R> StreamStage<R>	StreamStageWithKey.flatMapUsingService(ServiceFactory<?,S> serviceFactory, TriFunction<? super S,? super K,? super T,? extends Traverser<R>> flatMapFn)
<S, R> BatchStage<R>	BatchStage.mapUsingService(ServiceFactory<?,S> serviceFactory, BiFunctionEx<? super S,? super T,? extends R> mapFn)
<S, R> BatchStage<R>	BatchStageWithKey.mapUsingService(ServiceFactory<?,S> serviceFactory, TriFunction<? super S,? super K,? super T,? extends R> mapFn)
<S, R> GeneralStage<R>	GeneralStage.mapUsingService(ServiceFactory<?,S> serviceFactory, BiFunctionEx<? super S,? 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.
<S, R> GeneralStage<R>	GeneralStageWithKey.mapUsingService(ServiceFactory<?,S> serviceFactory, TriFunction<? super S,? 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.
<S, R> StreamStage<R>	StreamStage.mapUsingService(ServiceFactory<?,S> serviceFactory, BiFunctionEx<? super S,? super T,? extends R> mapFn)
<S, R> StreamStage<R>	StreamStageWithKey.mapUsingService(ServiceFactory<?,S> serviceFactory, TriFunction<? super S,? super K,? super T,? extends R> mapFn)
<S, R> BatchStage<R>	BatchStage.mapUsingServiceAsync(ServiceFactory<?,S> serviceFactory, int maxConcurrentOps, boolean preserveOrder, BiFunctionEx<? super S,? super T,? extends CompletableFuture<R>> mapAsyncFn)
default <S, R> BatchStage<R>	BatchStage.mapUsingServiceAsync(ServiceFactory<?,S> serviceFactory, BiFunctionEx<? super S,? super T,? extends CompletableFuture<R>> mapAsyncFn)
<S, R> BatchStage<R>	BatchStageWithKey.mapUsingServiceAsync(ServiceFactory<?,S> serviceFactory, int maxConcurrentOps, boolean preserveOrder, TriFunction<? super S,? super K,? super T,CompletableFuture<R>> mapAsyncFn)
default <S, R> BatchStage<R>	BatchStageWithKey.mapUsingServiceAsync(ServiceFactory<?,S> serviceFactory, TriFunction<? super S,? super K,? super T,CompletableFuture<R>> mapAsyncFn)
<S, R> GeneralStage<R>	GeneralStage.mapUsingServiceAsync(ServiceFactory<?,S> serviceFactory, int maxConcurrentOps, boolean preserveOrder, BiFunctionEx<? super S,? super T,? extends CompletableFuture<R>> mapAsyncFn)	Asynchronous version of GeneralStage.mapUsingService(com.hazelcast.jet.pipeline.ServiceFactory<?, S>, com.hazelcast.function.BiFunctionEx<? super S, ? super T, ? extends R>): the mapAsyncFn returns a CompletableFuture<R> instead of just R.
default <S, R> GeneralStage<R>	GeneralStage.mapUsingServiceAsync(ServiceFactory<?,S> serviceFactory, BiFunctionEx<? super S,? super T,? extends CompletableFuture<R>> mapAsyncFn)	Asynchronous version of GeneralStage.mapUsingService(com.hazelcast.jet.pipeline.ServiceFactory<?, S>, com.hazelcast.function.BiFunctionEx<? super S, ? super T, ? extends R>): the mapAsyncFn returns a CompletableFuture<R> instead of just R.
<S, R> GeneralStage<R>	GeneralStageWithKey.mapUsingServiceAsync(ServiceFactory<?,S> serviceFactory, int maxConcurrentOps, boolean preserveOrder, TriFunction<? super S,? super K,? super T,CompletableFuture<R>> mapAsyncFn)	Asynchronous version of GeneralStageWithKey.mapUsingService(com.hazelcast.jet.pipeline.ServiceFactory<?, S>, com.hazelcast.jet.function.TriFunction<? super S, ? super K, ? super T, ? extends R>): the mapAsyncFn returns a CompletableFuture<R> instead of just R.
default <S, R> GeneralStage<R>	GeneralStageWithKey.mapUsingServiceAsync(ServiceFactory<?,S> serviceFactory, TriFunction<? super S,? super K,? super T,CompletableFuture<R>> mapAsyncFn)	Asynchronous version of GeneralStageWithKey.mapUsingService(com.hazelcast.jet.pipeline.ServiceFactory<?, S>, com.hazelcast.jet.function.TriFunction<? super S, ? super K, ? super T, ? extends R>): the mapAsyncFn returns a CompletableFuture<R> instead of just R.
<S, R> StreamStage<R>	StreamStage.mapUsingServiceAsync(ServiceFactory<?,S> serviceFactory, int maxConcurrentOps, boolean preserveOrder, BiFunctionEx<? super S,? super T,? extends CompletableFuture<R>> mapAsyncFn)
default <S, R> StreamStage<R>	StreamStage.mapUsingServiceAsync(ServiceFactory<?,S> serviceFactory, BiFunctionEx<? super S,? super T,? extends CompletableFuture<R>> mapAsyncFn)
<S, R> StreamStage<R>	StreamStageWithKey.mapUsingServiceAsync(ServiceFactory<?,S> serviceFactory, int maxConcurrentOps, boolean preserveOrder, TriFunction<? super S,? super K,? super T,CompletableFuture<R>> mapAsyncFn)
default <S, R> StreamStage<R>	StreamStageWithKey.mapUsingServiceAsync(ServiceFactory<?,S> serviceFactory, TriFunction<? super S,? super K,? super T,CompletableFuture<R>> mapAsyncFn)
<S, R> BatchStage<R>	BatchStage.mapUsingServiceAsyncBatched(ServiceFactory<?,S> serviceFactory, int maxBatchSize, BiFunctionEx<? super S,? super List<T>,? extends CompletableFuture<List<R>>> mapAsyncFn)
<S, R> BatchStage<R>	BatchStageWithKey.mapUsingServiceAsyncBatched(ServiceFactory<?,S> serviceFactory, int maxBatchSize, BiFunctionEx<? super S,? super List<T>,? extends CompletableFuture<List<R>>> mapAsyncFn)
<S, R> BatchStage<R>	BatchStageWithKey.mapUsingServiceAsyncBatched(ServiceFactory<?,S> serviceFactory, int maxBatchSize, TriFunction<? super S,? super List<K>,? super List<T>,? extends CompletableFuture<List<R>>> mapAsyncFn)
<S, R> GeneralStage<R>	GeneralStage.mapUsingServiceAsyncBatched(ServiceFactory<?,S> serviceFactory, int maxBatchSize, BiFunctionEx<? super S,? super List<T>,? extends CompletableFuture<List<R>>> mapAsyncFn)	Batched version of GeneralStage.mapUsingServiceAsync(com.hazelcast.jet.pipeline.ServiceFactory<?, S>, com.hazelcast.function.BiFunctionEx<? super S, ? super T, ? extends java.util.concurrent.CompletableFuture<R>>): mapAsyncFn takes a list of input items and returns a CompletableFuture<List<R>>.
<S, R> GeneralStage<R>	GeneralStageWithKey.mapUsingServiceAsyncBatched(ServiceFactory<?,S> serviceFactory, int maxBatchSize, BiFunctionEx<? super S,? super List<T>,? extends CompletableFuture<List<R>>> mapAsyncFn)	Batched version of GeneralStageWithKey.mapUsingServiceAsync(com.hazelcast.jet.pipeline.ServiceFactory<?, S>, com.hazelcast.jet.function.TriFunction<? super S, ? super K, ? super T, java.util.concurrent.CompletableFuture<R>>): mapAsyncFn takes a list of input items and returns a CompletableFuture<List<R>>.
<S, R> GeneralStage<R>	GeneralStageWithKey.mapUsingServiceAsyncBatched(ServiceFactory<?,S> serviceFactory, int maxBatchSize, TriFunction<? super S,? super List<K>,? super List<T>,? extends CompletableFuture<List<R>>> mapAsyncFn)	Batched version of GeneralStageWithKey.mapUsingServiceAsync(com.hazelcast.jet.pipeline.ServiceFactory<?, S>, com.hazelcast.jet.function.TriFunction<? super S, ? super K, ? super T, java.util.concurrent.CompletableFuture<R>>): mapAsyncFn takes a list of input items (and a list of their corresponding keys) and returns a CompletableFuture<List<R>>.
<S, R> StreamStage<R>	StreamStage.mapUsingServiceAsyncBatched(ServiceFactory<?,S> serviceFactory, int maxBatchSize, BiFunctionEx<? super S,? super List<T>,? extends CompletableFuture<List<R>>> mapAsyncFn)
<S, R> StreamStage<R>	StreamStageWithKey.mapUsingServiceAsyncBatched(ServiceFactory<?,S> serviceFactory, int maxBatchSize, BiFunctionEx<? super S,? super List<T>,? extends CompletableFuture<List<R>>> mapAsyncFn)
<S, R> StreamStage<R>	StreamStageWithKey.mapUsingServiceAsyncBatched(ServiceFactory<?,S> serviceFactory, int maxBatchSize, TriFunction<? super S,? super List<K>,? super List<T>,? extends CompletableFuture<List<R>>> mapAsyncFn)

Uses of ServiceFactory in com.hazelcast.jet.spring

Methods in com.hazelcast.jet.spring that return ServiceFactory

Modifier and Type	Method	Description
static <T> ServiceFactory<?,T>	JetSpringServiceFactories.bean(Class<T> requiredType)	Returns a Spring Bean ServiceFactory.
static <T> ServiceFactory<?,T>	JetSpringServiceFactories.bean(String beanName)	Returns a Spring Bean ServiceFactory.
static <T> ServiceFactory<?,T>	JetSpringServiceFactories.bean(String beanName, Class<T> requiredType)	Returns a Spring Bean ServiceFactory.