Uses of Interface
com.hazelcast.jet.core.ProcessorSupplier.Context
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.Context in com.hazelcast.jet.core
Modifier and TypeInterfaceDescriptionstatic interface
Context passed to the processor in theinit()
call.Modifier and TypeMethodDescriptiondefault void
ProcessorSupplier.init
(ProcessorSupplier.Context context) Called on each cluster member after deserialization. -
Uses of ProcessorSupplier.Context in com.hazelcast.jet.core.processor
Modifier and TypeMethodDescriptionstatic <T> SupplierEx<Processor>
Processors.insertWatermarksP
(FunctionEx<ProcessorSupplier.Context, EventTimePolicy<? super T>> eventTimePolicyProvider) Returns a supplier of processors for a vertex that insertswatermark items
into the stream. -
Uses of ProcessorSupplier.Context in com.hazelcast.jet.core.test
Modifier and TypeClassDescriptionclass
Processor.Context
implementation suitable to be used in tests.class
Implementation ofProcessorSupplier.Context
suitable to be used in tests.Modifier and TypeMethodDescriptionTestSupport.supplierFrom
(ProcessorMetaSupplier supplier, ProcessorSupplier.Context context) Wraps the providedProcessorMetaSupplier
with aSupplier<Processor>
that returns processors obtained from it.TestSupport.supplierFrom
(ProcessorSupplier supplier, ProcessorSupplier.Context context) Wraps the providedProcessorSupplier
with aSupplier<Processor>
that returns processors obtained from it. -
Uses of ProcessorSupplier.Context in com.hazelcast.jet.pipeline
Modifier and TypeMethodDescriptionFunctionEx<? super ProcessorSupplier.Context,
? extends C> ServiceFactory.createContextFn()
Returns the function that creates the shared context object.Modifier and TypeMethodDescriptionstatic <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 aServiceFactory
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 newServiceFactory
with the given function that creates the shared context object.