Uses of Interface
com.hazelcast.jet.core.ProcessorSupplier

Packages that use ProcessorSupplier

Package	Description
com.hazelcast.jet.core	Jet's Core API.
com.hazelcast.jet.core.processor	Contains static utility classes with factories of Jet processors.
com.hazelcast.jet.core.test	Utilities for writing tests of Core API Processors.
com.hazelcast.jet.pipeline	The Pipeline API is Jet's high-level API to build and execute distributed computation jobs.

Uses of ProcessorSupplier in com.hazelcast.jet.core

Methods in com.hazelcast.jet.core that return ProcessorSupplier

Modifier and Type	Method and Description
static ProcessorSupplier	ProcessorSupplier.of(SupplierEx<? extends Processor> processorSupplier) Returns a ProcessorSupplier which will delegate to the given Supplier<Processor> to create all Processor instances.

Methods in com.hazelcast.jet.core that return types with arguments of type ProcessorSupplier

Modifier and Type	Method and Description
Function<? super Address,? extends ProcessorSupplier>	ProcessorMetaSupplier.get(List<Address> addresses) Called to create a mapping from member Address to the ProcessorSupplier that will be sent to that member.

Methods in com.hazelcast.jet.core with parameters of type ProcessorSupplier

Modifier and Type	Method and Description
static ProcessorMetaSupplier	ProcessorMetaSupplier.forceTotalParallelismOne(ProcessorSupplier supplier) Variant of ProcessorMetaSupplier.forceTotalParallelismOne(ProcessorSupplier, String) where the node for the supplier will be chosen randomly.
static ProcessorMetaSupplier	ProcessorMetaSupplier.forceTotalParallelismOne(ProcessorSupplier supplier, Address memberAddress) Wraps the provided ProcessorSupplier into a meta-supplier that will only use the given ProcessorSupplier on a node with the given Address.
static ProcessorMetaSupplier	ProcessorMetaSupplier.forceTotalParallelismOne(ProcessorSupplier supplier, String partitionKey) Wraps the provided ProcessorSupplier into a meta-supplier that will only use the given ProcessorSupplier on a single node.
Vertex	DAG.newUniqueVertex(String namePrefix, ProcessorSupplier processorSupplier) Creates a vertex from a ProcessorSupplier and adds it to this DAG.
Vertex	DAG.newVertex(String name, ProcessorSupplier processorSupplier) Creates a vertex from a ProcessorSupplier and adds it to this DAG.
static ProcessorMetaSupplier	ProcessorMetaSupplier.of(int preferredLocalParallelism, ProcessorSupplier procSupplier) Factory method that wraps the given ProcessorSupplier and returns the same instance for each given Address.
static ProcessorMetaSupplier	ProcessorMetaSupplier.of(ProcessorSupplier procSupplier) Wraps the provided ProcessorSupplier into a meta-supplier that will always return it.
static ProcessorMetaSupplier	ProcessorMetaSupplier.preferLocalParallelismOne(ProcessorSupplier supplier) Wraps the provided ProcessorSupplier into a meta-supplier that will always return it.

Method parameters in com.hazelcast.jet.core with type arguments of type ProcessorSupplier

Modifier and Type	Method and Description
static ProcessorMetaSupplier	ProcessorMetaSupplier.of(FunctionEx<? super Address,? extends ProcessorSupplier> addressToSupplier) Factory method that creates a ProcessorMetaSupplier from the supplied function that maps a cluster member address to a ProcessorSupplier.
static ProcessorMetaSupplier	ProcessorMetaSupplier.of(int preferredLocalParallelism, FunctionEx<? super Address,? extends ProcessorSupplier> addressToSupplier) Factory method that creates a ProcessorMetaSupplier from the supplied function that maps a cluster member address to a ProcessorSupplier.

Constructors in com.hazelcast.jet.core with parameters of type ProcessorSupplier

Constructor and Description
Vertex(String name, ProcessorSupplier processorSupplier) Creates a vertex from a ProcessorSupplier.

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

Methods in com.hazelcast.jet.core.processor that return ProcessorSupplier

Modifier and Type	Method and 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.
static <T> ProcessorSupplier	DiagnosticProcessors.peekInputP(FunctionEx<T,? extends CharSequence> toStringFn, PredicateEx<T> shouldLogFn, ProcessorSupplier wrapped) Same as peekInput(toStringFn, shouldLogFn, metaSupplier), but accepts a ProcessorSupplier instead of a meta-supplier.
static ProcessorSupplier	DiagnosticProcessors.peekInputP(ProcessorSupplier wrapped) Convenience for peekInput(toStringFn, shouldLogFn, metaSupplier) with a pass-through filter and Object#toString as the formatting function.
static <T> ProcessorSupplier	DiagnosticProcessors.peekOutputP(FunctionEx<? super T,? extends CharSequence> toStringFn, PredicateEx<? super T> shouldLogFn, ProcessorSupplier wrapped) Same as peekOutput(toStringFn, shouldLogFn, metaSupplier), but accepts a ProcessorSupplier instead of a meta-supplier.
static ProcessorSupplier	DiagnosticProcessors.peekOutputP(ProcessorSupplier wrapped) Convenience for peekOutput(toStringFn, shouldLogFn, metaSupplier with a pass-through filter and Object#toString as 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 as peekSnapshot(toStringFn, shouldLogFn, metaSupplier), but accepts a ProcessorSupplier instead of a meta-supplier.
static ProcessorSupplier	DiagnosticProcessors.peekSnapshotP(ProcessorSupplier wrapped) Convenience for peekSnapshot(toStringFn, shouldLogFn, metaSupplier with a pass-through filter and Object#toString as the formatting function.
static ProcessorSupplier	SourceProcessors.readRemoteCacheP(String cacheName, ClientConfig clientConfig) Returns a supplier of processors for Sources.remoteCache(String, ClientConfig).
static ProcessorSupplier	SourceProcessors.readRemoteMapP(String mapName, ClientConfig clientConfig) Returns a supplier of processors for Sources.remoteMap(String, ClientConfig).
static <T,K,V> ProcessorSupplier	SourceProcessors.readRemoteMapP(String mapName, ClientConfig clientConfig, Predicate<K,V> predicate, Projection<? super Map.Entry<K,V>,? extends T> projection) Returns a supplier of processors for Sources.remoteMap(String, ClientConfig, Predicate, Projection).

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

Modifier and Type	Method and Description
static <T> ProcessorSupplier	DiagnosticProcessors.peekInputP(FunctionEx<T,? extends CharSequence> toStringFn, PredicateEx<T> shouldLogFn, ProcessorSupplier wrapped) Same as peekInput(toStringFn, shouldLogFn, metaSupplier), but accepts a ProcessorSupplier instead of a meta-supplier.
static ProcessorSupplier	DiagnosticProcessors.peekInputP(ProcessorSupplier wrapped) Convenience for peekInput(toStringFn, shouldLogFn, metaSupplier) with a pass-through filter and Object#toString as the formatting function.
static <T> ProcessorSupplier	DiagnosticProcessors.peekOutputP(FunctionEx<? super T,? extends CharSequence> toStringFn, PredicateEx<? super T> shouldLogFn, ProcessorSupplier wrapped) Same as peekOutput(toStringFn, shouldLogFn, metaSupplier), but accepts a ProcessorSupplier instead of a meta-supplier.
static ProcessorSupplier	DiagnosticProcessors.peekOutputP(ProcessorSupplier wrapped) Convenience for peekOutput(toStringFn, shouldLogFn, metaSupplier with a pass-through filter and Object#toString as 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 as peekSnapshot(toStringFn, shouldLogFn, metaSupplier), but accepts a ProcessorSupplier instead of a meta-supplier.
static ProcessorSupplier	DiagnosticProcessors.peekSnapshotP(ProcessorSupplier wrapped) Convenience for peekSnapshot(toStringFn, shouldLogFn, metaSupplier with a pass-through filter and Object#toString as the formatting function.

Uses of ProcessorSupplier in com.hazelcast.jet.core.test

Methods in com.hazelcast.jet.core.test with parameters of type ProcessorSupplier

Modifier and Type	Method and Description
static Supplier<Processor>	TestSupport.supplierFrom(ProcessorSupplier supplier) Wraps the provided ProcessorSupplier with a Supplier<Processor> that returns processors obtained from it.
static Supplier<Processor>	TestSupport.supplierFrom(ProcessorSupplier supplier, ProcessorSupplier.Context context) Wraps the provided ProcessorSupplier with a Supplier<Processor> that returns processors obtained from it.
static TestSupport	TestSupport.verifyProcessor(ProcessorSupplier supplier)

Uses of ProcessorSupplier in com.hazelcast.jet.pipeline

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

Modifier and Type	Method and Description
default <R> StreamStage<R>	StreamStageWithKey.customTransform(String stageName, ProcessorSupplier procSupplier)
<R> GeneralStage<R>	GeneralStageWithKey.customTransform(String stageName, ProcessorSupplier procSupplier) Attaches a stage with a custom transform based on the provided supplier of Core API Processors.
default <R> BatchStage<R>	BatchStageWithKey.customTransform(String stageName, ProcessorSupplier procSupplier)
default <R> StreamStage<R>	StreamStage.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 API Processors.
default <R> BatchStage<R>	BatchStage.customTransform(String stageName, ProcessorSupplier procSupplier)