Uses of Interface
com.hazelcast.jet.core.ProcessorSupplier
Packages that use ProcessorSupplier
Package
Description
Jet's Core API.
Contains static utility classes with factories of Jet processors.
Utilities for writing tests of Core API Processors.
The Pipeline API is Jet's high-level API to build and execute
distributed computation jobs.
-
Uses of ProcessorSupplier in com.hazelcast.jet.core
Classes in com.hazelcast.jet.core that implement ProcessorSupplierModifier and TypeClassDescriptionstatic classFields in com.hazelcast.jet.core declared as ProcessorSupplierModifier and TypeFieldDescriptionprotected ProcessorSupplierProcessorMetaSupplier.SpecificMemberPms.supplierMethods in com.hazelcast.jet.core that return ProcessorSupplierModifier and TypeMethodDescriptionstatic ProcessorSupplierProcessorSupplier.of(SupplierEx<? extends Processor> processorSupplier) Returns aProcessorSupplierwhich will delegate to the givenSupplier<Processor>to create allProcessorinstances.Methods in com.hazelcast.jet.core that return types with arguments of type ProcessorSupplierModifier and TypeMethodDescriptionFunction<? super Address,? extends ProcessorSupplier> Called to create a mapping from memberAddressto theProcessorSupplierthat will be sent to that member.Function<? super Address,? extends ProcessorSupplier> Function<? super Address,? extends ProcessorSupplier> Methods in com.hazelcast.jet.core with parameters of type ProcessorSupplierModifier and TypeMethodDescriptionstatic ProcessorMetaSupplierProcessorMetaSupplier.forceTotalParallelismOne(ProcessorSupplier supplier) Variant ofProcessorMetaSupplier.forceTotalParallelismOne(ProcessorSupplier, String, Permission)where the node for the supplier will be chosen randomly and without any required permission.static ProcessorMetaSupplierProcessorMetaSupplier.forceTotalParallelismOne(ProcessorSupplier supplier, Address memberAddress) Wraps the providedProcessorSupplierinto a meta-supplier that will only use the givenProcessorSupplieron a node with the givenAddress.static ProcessorMetaSupplierProcessorMetaSupplier.forceTotalParallelismOne(ProcessorSupplier supplier, String partitionKey) Variant ofProcessorMetaSupplier.forceTotalParallelismOne(ProcessorSupplier, String, Permission)without any required permission.static ProcessorMetaSupplierProcessorMetaSupplier.forceTotalParallelismOne(ProcessorSupplier supplier, String partitionKey, Permission permission) Wraps the providedProcessorSupplierinto a meta-supplier that will only use the givenProcessorSupplieron a single node.static ProcessorMetaSupplierProcessorMetaSupplier.forceTotalParallelismOne(ProcessorSupplier supplier, Permission permission) Variant ofProcessorMetaSupplier.forceTotalParallelismOne(ProcessorSupplier, String, Permission)where the node for the supplier will be chosen randomly.DAG.newUniqueVertex(String namePrefix, ProcessorSupplier processorSupplier) Creates a vertex from aProcessorSupplierand adds it to this DAG.DAG.newVertex(String name, ProcessorSupplier processorSupplier) Creates a vertex from aProcessorSupplierand adds it to this DAG.static ProcessorMetaSupplierProcessorMetaSupplier.of(int preferredLocalParallelism, ProcessorSupplier procSupplier) Variant ofProcessorMetaSupplier.of(int, Permission, ProcessorSupplier)where the processor does not require any permission to run.static ProcessorMetaSupplierProcessorMetaSupplier.of(int preferredLocalParallelism, Permission permission, ProcessorSupplier procSupplier) Factory method that wraps the givenProcessorSupplierand returns the same instance for each givenAddress.static ProcessorMetaSupplierProcessorMetaSupplier.of(ProcessorSupplier procSupplier) Variant ofProcessorMetaSupplier.of(Permission, ProcessorSupplier)where the processor does not require any permission to run.static ProcessorMetaSupplierProcessorMetaSupplier.of(Permission permission, ProcessorSupplier procSupplier) Wraps the providedProcessorSupplierinto a meta-supplier that will always return it.static ProcessorMetaSupplierProcessorMetaSupplier.preferLocalParallelismOne(ProcessorSupplier supplier) Wraps the providedProcessorSupplierinto a meta-supplier that will always return it.static ProcessorMetaSupplierProcessorMetaSupplier.preferLocalParallelismOne(Permission permission, ProcessorSupplier supplier) Variant ofProcessorMetaSupplier.preferLocalParallelismOne(ProcessorSupplier)where the processor requires given permission to run.static ProcessorMetaSupplierProcessorMetaSupplier.randomMember(ProcessorSupplier supplier) Wraps the providedProcessorSupplierinto a meta-supplier that will only use the givenProcessorSupplieron a random nodeMethod parameters in com.hazelcast.jet.core with type arguments of type ProcessorSupplierModifier and TypeMethodDescriptionstatic ProcessorMetaSupplierProcessorMetaSupplier.of(int preferredLocalParallelism, FunctionEx<? super Address, ? extends ProcessorSupplier> addressToSupplier) Factory method that creates aProcessorMetaSupplierfrom the supplied function that maps a cluster member address to aProcessorSupplier.static ProcessorMetaSupplierProcessorMetaSupplier.of(FunctionEx<? super Address, ? extends ProcessorSupplier> addressToSupplier) Factory method that creates aProcessorMetaSupplierfrom the supplied function that maps a cluster member address to aProcessorSupplier.Constructors in com.hazelcast.jet.core with parameters of type ProcessorSupplierModifierConstructorDescriptionprotectedSpecificMemberPms(ProcessorSupplier supplier, Address memberAddress) Vertex(String name, ProcessorSupplier processorSupplier) Creates a vertex from aProcessorSupplier. -
Uses of ProcessorSupplier in com.hazelcast.jet.core.processor
Methods in com.hazelcast.jet.core.processor that return ProcessorSupplierModifier 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.static <T> ProcessorSupplierDiagnosticProcessors.peekInputP(FunctionEx<T, ? extends CharSequence> toStringFn, PredicateEx<T> shouldLogFn, ProcessorSupplier wrapped) Same aspeekInput(toStringFn, shouldLogFn, metaSupplier), but accepts aProcessorSupplierinstead of a meta-supplier.static ProcessorSupplierDiagnosticProcessors.peekInputP(ProcessorSupplier wrapped) Convenience forpeekInput(toStringFn, shouldLogFn, metaSupplier)with a pass-through filter andObject#toStringas the formatting function.static <T> ProcessorSupplierDiagnosticProcessors.peekOutputP(FunctionEx<? super T, ? extends CharSequence> toStringFn, PredicateEx<? super T> shouldLogFn, ProcessorSupplier wrapped) Same aspeekOutput(toStringFn, shouldLogFn, metaSupplier), but accepts aProcessorSupplierinstead of a meta-supplier.static ProcessorSupplierDiagnosticProcessors.peekOutputP(ProcessorSupplier wrapped) Convenience forpeekOutput(toStringFn, shouldLogFn, metaSupplierwith a pass-through filter andObject#toStringas the formatting function.static <K,V> ProcessorSupplier DiagnosticProcessors.peekSnapshotP(FunctionEx<? super Map.Entry<K, V>, ? extends CharSequence> toStringFn, PredicateEx<? super Map.Entry<K, V>> shouldLogFn, ProcessorSupplier wrapped) Same aspeekSnapshot(toStringFn, shouldLogFn, metaSupplier), but accepts aProcessorSupplierinstead of a meta-supplier.static ProcessorSupplierDiagnosticProcessors.peekSnapshotP(ProcessorSupplier wrapped) Convenience forpeekSnapshot(toStringFn, shouldLogFn, metaSupplierwith a pass-through filter andObject#toStringas the formatting function.static ProcessorSupplierSourceProcessors.readRemoteCacheP(String cacheName, ClientConfig clientConfig) Returns a supplier of processors forSources.remoteCache(String, ClientConfig).Methods in com.hazelcast.jet.core.processor with parameters of type ProcessorSupplierModifier and TypeMethodDescriptionstatic <T> ProcessorSupplierDiagnosticProcessors.peekInputP(FunctionEx<T, ? extends CharSequence> toStringFn, PredicateEx<T> shouldLogFn, ProcessorSupplier wrapped) Same aspeekInput(toStringFn, shouldLogFn, metaSupplier), but accepts aProcessorSupplierinstead of a meta-supplier.static ProcessorSupplierDiagnosticProcessors.peekInputP(ProcessorSupplier wrapped) Convenience forpeekInput(toStringFn, shouldLogFn, metaSupplier)with a pass-through filter andObject#toStringas the formatting function.static <T> ProcessorSupplierDiagnosticProcessors.peekOutputP(FunctionEx<? super T, ? extends CharSequence> toStringFn, PredicateEx<? super T> shouldLogFn, ProcessorSupplier wrapped) Same aspeekOutput(toStringFn, shouldLogFn, metaSupplier), but accepts aProcessorSupplierinstead of a meta-supplier.static ProcessorSupplierDiagnosticProcessors.peekOutputP(ProcessorSupplier wrapped) Convenience forpeekOutput(toStringFn, shouldLogFn, metaSupplierwith a pass-through filter andObject#toStringas the formatting function.static <K,V> ProcessorSupplier DiagnosticProcessors.peekSnapshotP(FunctionEx<? super Map.Entry<K, V>, ? extends CharSequence> toStringFn, PredicateEx<? super Map.Entry<K, V>> shouldLogFn, ProcessorSupplier wrapped) Same aspeekSnapshot(toStringFn, shouldLogFn, metaSupplier), but accepts aProcessorSupplierinstead of a meta-supplier.static ProcessorSupplierDiagnosticProcessors.peekSnapshotP(ProcessorSupplier wrapped) Convenience forpeekSnapshot(toStringFn, shouldLogFn, metaSupplierwith a pass-through filter andObject#toStringas the formatting function. -
Uses of ProcessorSupplier in com.hazelcast.jet.core.test
Methods in com.hazelcast.jet.core.test with parameters of type ProcessorSupplierModifier and TypeMethodDescriptionTestSupport.supplierFrom(ProcessorSupplier supplier) Wraps the providedProcessorSupplierwith aSupplier<Processor>that returns processors obtained from it.TestSupport.supplierFrom(ProcessorSupplier supplier, ProcessorSupplier.Context context) Wraps the providedProcessorSupplierwith aSupplier<Processor>that returns processors obtained from it.static TestSupportTestSupport.verifyProcessor(ProcessorSupplier supplier) -
Uses of ProcessorSupplier in com.hazelcast.jet.pipeline
Methods in com.hazelcast.jet.pipeline with parameters of type ProcessorSupplierModifier and TypeMethodDescriptiondefault <R> BatchStage<R>BatchStage.customTransform(String stageName, ProcessorSupplier procSupplier) default <R> BatchStage<R>BatchStageWithKey.customTransform(String stageName, ProcessorSupplier procSupplier) <R> GeneralStage<R>GeneralStage.customTransform(String stageName, ProcessorSupplier procSupplier) Attaches a stage with a custom transform based on the provided supplier of Core APIProcessors.<R> GeneralStage<R>GeneralStageWithKey.customTransform(String stageName, ProcessorSupplier procSupplier) Attaches a stage with a custom transform based on the provided supplier of Core APIProcessors.default <R> StreamStage<R>StreamStage.customTransform(String stageName, ProcessorSupplier procSupplier) default <R> StreamStage<R>StreamStageWithKey.customTransform(String stageName, ProcessorSupplier procSupplier)