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

Classes in com.hazelcast.jet.core that implement ProcessorSupplier

Modifier and Type	Class	Description
static class	ProcessorMetaSupplier.ExpectNothingProcessorSupplier

Fields in com.hazelcast.jet.core declared as ProcessorSupplier

Modifier and Type	Field	Description
protected ProcessorSupplier	ProcessorMetaSupplier.SpecificMemberPms.supplier

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

Modifier and Type	Method	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	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.
Function<? super Address,? extends ProcessorSupplier>	ProcessorMetaSupplier.RandomMemberPms.get(List<Address> addresses)
Function<? super Address,? extends ProcessorSupplier>	ProcessorMetaSupplier.SpecificMemberPms.get(List<Address> addresses)

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

Modifier and Type	Method	Description
static ProcessorMetaSupplier	ProcessorMetaSupplier.forceTotalParallelismOne(ProcessorSupplier supplier)	Variant of ProcessorMetaSupplier.forceTotalParallelismOne(ProcessorSupplier, String, Permission) where the node for the supplier will be chosen randomly and without any required permission.
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)	Variant of ProcessorMetaSupplier.forceTotalParallelismOne(ProcessorSupplier, String, Permission) without any required permission.
static ProcessorMetaSupplier	ProcessorMetaSupplier.forceTotalParallelismOne(ProcessorSupplier supplier, String partitionKey, Permission permission)	Wraps the provided ProcessorSupplier into a meta-supplier that will only use the given ProcessorSupplier on a single node.
static ProcessorMetaSupplier	ProcessorMetaSupplier.forceTotalParallelismOne(ProcessorSupplier supplier, Permission permission)	Variant of ProcessorMetaSupplier.forceTotalParallelismOne(ProcessorSupplier, String, Permission) where the node for the supplier will be chosen randomly.
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)	Variant of ProcessorMetaSupplier.of(int, Permission, ProcessorSupplier) where the processor does not require any permission to run.
static ProcessorMetaSupplier	ProcessorMetaSupplier.of(int preferredLocalParallelism, Permission permission, ProcessorSupplier procSupplier)	Factory method that wraps the given ProcessorSupplier and returns the same instance for each given Address.
static ProcessorMetaSupplier	ProcessorMetaSupplier.of(ProcessorSupplier procSupplier)	Variant of ProcessorMetaSupplier.of(Permission, ProcessorSupplier) where the processor does not require any permission to run.
static ProcessorMetaSupplier	ProcessorMetaSupplier.of(Permission permission, 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.
static ProcessorMetaSupplier	ProcessorMetaSupplier.preferLocalParallelismOne(Permission permission, ProcessorSupplier supplier)	Variant of ProcessorMetaSupplier.preferLocalParallelismOne(ProcessorSupplier) where the processor requires given permission to run.
static ProcessorMetaSupplier	ProcessorMetaSupplier.randomMember(ProcessorSupplier supplier)	Wraps the provided ProcessorSupplier into a meta-supplier that will only use the given ProcessorSupplier on a random node

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

Modifier and Type	Method	Description
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.
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.

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

Modifier	Constructor	Description
protected	SpecificMemberPms(ProcessorSupplier supplier, Address memberAddress)
	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	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).

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

Modifier and Type	Method	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	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	Description
default <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 API Processors.
<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> StreamStage<R>	StreamStage.customTransform(String stageName, ProcessorSupplier procSupplier)
default <R> StreamStage<R>	StreamStageWithKey.customTransform(String stageName, ProcessorSupplier procSupplier)