Uses of Class
com.hazelcast.jet.pipeline.ServiceFactory
Packages that use ServiceFactory
Package
Description
Contains static utility classes with factories of Jet processors.
Contributes
gRPC service factories that can be to apply transformations to
a pipeline which for each input item calls to a gRPC service.The Pipeline API is Jet's high-level API to build and execute
distributed computation jobs.
Provides Jet related Spring interfaces/classes for Hazelcast.
-
Uses of ServiceFactory in com.hazelcast.jet.core.processor
Methods in com.hazelcast.jet.core.processor with parameters of type ServiceFactoryModifier and TypeMethodDescriptionstatic <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>
ProcessorSupplierProcessors.mapUsingServiceAsyncP(ServiceFactory<C, S> serviceFactory, int maxConcurrentOps, boolean preserveOrder, FunctionEx<T, K> extractKeyFn, BiFunctionEx<? super S, ? super T, CompletableFuture<R>> mapAsyncFn) Asynchronous version ofProcessors.mapUsingServiceP(com.hazelcast.jet.pipeline.ServiceFactory<C, S>, com.hazelcast.function.BiFunctionEx<? super S, ? super T, ? extends R>): themapAsyncFnreturns aCompletableFuture<R>instead of justR.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.grpc
Methods in com.hazelcast.jet.grpc that return ServiceFactoryModifier and TypeMethodDescriptionstatic <T,R> ServiceFactory<?, ? extends GrpcService<T, R>> GrpcServices.bidirectionalStreamingService(SupplierEx<? extends io.grpc.ManagedChannelBuilder<?>> channelFn, FunctionEx<? super io.grpc.ManagedChannel, ? extends FunctionEx<io.grpc.stub.StreamObserver<R>, io.grpc.stub.StreamObserver<T>>> callStubFn) Creates aServiceFactorythat calls out to a bidirectional streaming gRPC service.static <T,R> ServiceFactory<?, ? extends GrpcService<T, R>> GrpcServices.unaryService(SupplierEx<? extends io.grpc.ManagedChannelBuilder<?>> channelFn, FunctionEx<? super io.grpc.ManagedChannel, ? extends BiConsumerEx<T, io.grpc.stub.StreamObserver<R>>> callStubFn) Creates aServiceFactorythat calls out to a unary gRPC service. -
Uses of ServiceFactory in com.hazelcast.jet.pipeline
Methods in com.hazelcast.jet.pipeline that return ServiceFactoryModifier and TypeMethodDescriptionprotected ServiceFactory<C,S> ServiceFactory.clone()static <K,V> ServiceFactory<?, IMap<K, V>> ServiceFactories.iMapService(String mapName) Returns a factory that provides anIMapas the service.static <S> ServiceFactory<?,S> ServiceFactories.nonSharedService(FunctionEx<? super Processor.Context, ? extends S> createServiceFn) A variant ofnonSharedService(createFn, destroyFn)with a no-opdestroyFn.static <S> ServiceFactory<?,S> ServiceFactories.nonSharedService(FunctionEx<? super Processor.Context, ? extends S> createServiceFn, ConsumerEx<? super S> destroyServiceFn) Returns aServiceFactorywhich 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 aReplicatedMapas the service object.ServiceFactory.setCooperative(boolean cooperative) Returns a copy of thisServiceFactorywith theisCooperativeflag set tocooperativeargument value.static <S> ServiceFactory<?,S> ServiceFactories.sharedService(FunctionEx<? super ProcessorSupplier.Context, S> createServiceFn) A variant ofsharedService(createFn, destroyFn)with a no-opdestroyFn.static <S> ServiceFactory<?,S> ServiceFactories.sharedService(FunctionEx<? super ProcessorSupplier.Context, S> createServiceFn, ConsumerEx<S> destroyServiceFn) Returns aServiceFactorywhich will provide a single shared service object per cluster member.ServiceFactory.toNonCooperative()Returns a copy of thisServiceFactorywith theisCooperativeflag set tofalse.ServiceFactory.withAttachedDirectory(String id, File directory) Attaches a directory to this service factory under the given ID.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 newServiceFactorywith 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 thisServiceFactorywith the givencreateServicefunction.ServiceFactory.withDestroyContextFn(ConsumerEx<? super C> destroyContextFn) Returns a copy of thisServiceFactorywith thedestroyContextfunction replaced with the given function.ServiceFactory.withDestroyServiceFn(ConsumerEx<? super S> destroyServiceFn) Returns a copy of thisServiceFactorywith thedestroyServicefunction replaced with the given function.ServiceFactory.withoutAttachedFiles()Returns a copy of thisServiceFactorywith any attached files removed.ServiceFactory.withPermission(Permission permission) Returns a copy of thisServiceFactorywith setting the required permission.Methods in com.hazelcast.jet.pipeline with parameters of type ServiceFactoryModifier and TypeMethodDescription<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) Deprecated.<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 theTraverserit 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) Deprecated.Jet now has first-class support for data rebalancing, seeGeneralStage.rebalance()andGeneralStage.rebalance(FunctionEx).<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) Deprecated.Jet now has first-class support for data rebalancing, seeGeneralStage.rebalance()andGeneralStage.rebalance(FunctionEx).<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 ofGeneralStage.mapUsingService(com.hazelcast.jet.pipeline.ServiceFactory<?, S>, com.hazelcast.function.BiFunctionEx<? super S, ? super T, ? extends R>): themapAsyncFnreturns aCompletableFuture<R>instead of justR.default <S,R> GeneralStage<R> GeneralStage.mapUsingServiceAsync(ServiceFactory<?, S> serviceFactory, BiFunctionEx<? super S, ? super T, ? extends CompletableFuture<R>> mapAsyncFn) Asynchronous version ofGeneralStage.mapUsingService(com.hazelcast.jet.pipeline.ServiceFactory<?, S>, com.hazelcast.function.BiFunctionEx<? super S, ? super T, ? extends R>): themapAsyncFnreturns aCompletableFuture<R>instead of justR.<S,R> GeneralStage<R> GeneralStageWithKey.mapUsingServiceAsync(ServiceFactory<?, S> serviceFactory, int maxConcurrentOps, boolean preserveOrder, TriFunction<? super S, ? super K, ? super T, CompletableFuture<R>> mapAsyncFn) Deprecated.Jet now has first-class support for data rebalancing, seeGeneralStage.rebalance()andGeneralStage.rebalance(FunctionEx).default <S,R> GeneralStage<R> GeneralStageWithKey.mapUsingServiceAsync(ServiceFactory<?, S> serviceFactory, TriFunction<? super S, ? super K, ? super T, CompletableFuture<R>> mapAsyncFn) Deprecated.Jet now has first-class support for data rebalancing, seeGeneralStage.rebalance()andGeneralStage.rebalance(FunctionEx).<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 ofGeneralStage.mapUsingServiceAsync(com.hazelcast.jet.pipeline.ServiceFactory<?, S>, com.hazelcast.function.BiFunctionEx<? super S, ? super T, ? extends java.util.concurrent.CompletableFuture<R>>):mapAsyncFntakes a list of input items and returns aCompletableFuture<List<R>>.<S,R> GeneralStage<R> GeneralStageWithKey.mapUsingServiceAsyncBatched(ServiceFactory<?, S> serviceFactory, int maxBatchSize, BiFunctionEx<? super S, ? super List<T>, ? extends CompletableFuture<List<R>>> mapAsyncFn) Deprecated.Jet now has first-class support for data rebalancing, seeGeneralStage.rebalance()andGeneralStage.rebalance(FunctionEx).<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) Deprecated.Jet now has first-class support for data rebalancing, seeGeneralStage.rebalance()andGeneralStage.rebalance(FunctionEx).<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.spring.jet
Methods in com.hazelcast.spring.jet that return ServiceFactoryModifier and TypeMethodDescriptionstatic <T> ServiceFactory<?,T> Returns a Spring BeanServiceFactory.static <T> ServiceFactory<?,T> Returns a Spring BeanServiceFactory.static <T> ServiceFactory<?,T> Returns a Spring BeanServiceFactory.
GeneralStage.rebalance()andGeneralStage.rebalance(FunctionEx).