Uses of Interface
com.hazelcast.jet.core.ProcessorSupplier.Context
Package | Description |
---|---|
com.hazelcast.jet.core |
Jet's Core API.
|
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 theinit()
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.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 ofProcessorSupplier.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 providedProcessorMetaSupplier
with aSupplier<Processor>
that returns processors obtained from it.static Supplier<Processor>
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
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 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.