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

Packages that use ProcessorSupplier.Context

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.Context in com.hazelcast.jet.core

Subinterfaces of ProcessorSupplier.Context in com.hazelcast.jet.core

Modifier and Type	Interface	Description
static interface	Processor.Context	Context passed to the processor in the init() call.

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

Modifier and Type	Method	Description
default void	ProcessorSupplier.init(ProcessorSupplier.Context context)	Called on each cluster member after deserialization.

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

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

Modifier and Type	Method	Description
static <T> SupplierEx<Processor>	Processors.insertWatermarksP(FunctionEx<ProcessorSupplier.Context,EventTimePolicy<? super T>> eventTimePolicyProvider)	Returns a supplier of processors for a vertex that inserts watermark items into the stream.

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

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

Modifier and Type	Class	Description
class	TestProcessorContext	Processor.Context implementation suitable to be used in tests.
class	TestProcessorSupplierContext	Implementation of ProcessorSupplier.Context suitable to be used in tests.

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

Modifier and Type	Method	Description
static Supplier<Processor>	TestSupport.supplierFrom(ProcessorMetaSupplier supplier, ProcessorSupplier.Context context)	Wraps the provided ProcessorMetaSupplier 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.

Uses of ProcessorSupplier.Context in com.hazelcast.jet.pipeline

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

Modifier and Type	Method	Description
FunctionEx<? super ProcessorSupplier.Context,? extends C>	ServiceFactory.createContextFn()	Returns the function that creates the shared context object.

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

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