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

Packages that use Processor.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.
com.hazelcast.jet.pipeline.test	This package contains various mock sources to help with pipeline testing and development.

Uses of Processor.Context in com.hazelcast.jet.core

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

Modifier and Type	Method and Description
void	AbstractProcessor.init(Outbox outbox, Processor.Context context)
default void	Processor.init(Outbox outbox, Processor.Context context) Initializes this processor with the outbox that the processing methods must use to deposit their output items.
protected void	AbstractProcessor.init(Processor.Context context) Method that can be overridden to perform any necessary initialization for the processor.

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

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

Modifier and Type	Method and Description
static <C,T,S> ProcessorMetaSupplier	SourceProcessors.convenientSourceP(FunctionEx<? super Processor.Context,? extends C> createFn, BiConsumerEx<? super C,? super SourceBuilder.SourceBuffer<T>> fillBufferFn, FunctionEx<? super C,? extends S> createSnapshotFn, BiConsumerEx<? super C,? super List<S>> restoreSnapshotFn, ConsumerEx<? super C> destroyFn, int preferredLocalParallelism, boolean isBatch) Returns a supplier of processors for a source that the user can create using the SourceBuilder.
static <C,T,S> ProcessorMetaSupplier	SourceProcessors.convenientTimestampedSourceP(FunctionEx<? super Processor.Context,? extends C> createFn, BiConsumerEx<? super C,? super SourceBuilder.TimestampedSourceBuffer<T>> fillBufferFn, EventTimePolicy<? super T> eventTimePolicy, FunctionEx<? super C,? extends S> createSnapshotFn, BiConsumerEx<? super C,? super List<S>> restoreSnapshotFn, ConsumerEx<? super C> destroyFn, int preferredLocalParallelism) Returns a supplier of processors for a source that the user can create using the SourceBuilder.
static <W,T> SupplierEx<Processor>	SinkProcessors.writeBufferedP(FunctionEx<? super Processor.Context,? extends W> createFn, BiConsumerEx<? super W,? super T> onReceiveFn, ConsumerEx<? super W> flushFn) Shortcut for SinkProcessors.writeBufferedP(FunctionEx, BiConsumerEx, ConsumerEx, ConsumerEx) with a no-op destroyFn.
static <W,T> SupplierEx<Processor>	SinkProcessors.writeBufferedP(FunctionEx<? super Processor.Context,? extends W> createFn, BiConsumerEx<? super W,? super T> onReceiveFn, ConsumerEx<? super W> flushFn, ConsumerEx<? super W> destroyFn) Returns a supplier of processors for a vertex that drains all the items from the inbox to an internal writer object and then does a flush.

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

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

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

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

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

Modifier and Type	Method and Description
BiFunctionEx<? super Processor.Context,? super C,? extends S>	ServiceFactory.createServiceFn() Returns the function that creates the service object.

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

Modifier and Type	Method and Description
static <C> SourceBuilder.Batch<Void>	SourceBuilder.batch(String name, FunctionEx<? super Processor.Context,? extends C> createFn) Returns a fluent-API builder with which you can create a batch source for a Jet pipeline.
static <S> ServiceFactory<?,S>	ServiceFactories.nonSharedService(FunctionEx<? super Processor.Context,? extends S> createServiceFn) A variant of nonSharedService(createFn, destroyFn) with a no-op destroyFn.
static <S> ServiceFactory<?,S>	ServiceFactories.nonSharedService(FunctionEx<? super Processor.Context,? extends S> createServiceFn, ConsumerEx<? super S> destroyServiceFn) Returns a ServiceFactory which creates a separate service instance for each parallel Jet processor.
static <C> SinkBuilder<C,Void>	SinkBuilder.sinkBuilder(String name, FunctionEx<Processor.Context,? extends C> createFn) Returns a builder object that offers a step-by-step fluent API to build a custom Sink for the Pipeline API.
static <C> SourceBuilder.Stream<Void>	SourceBuilder.stream(String name, FunctionEx<? super Processor.Context,? extends C> createFn) Returns a fluent-API builder with which you can create an unbounded stream source for a Jet pipeline.
static <C> SourceBuilder.TimestampedStream<Void>	SourceBuilder.timestampedStream(String name, FunctionEx<? super Processor.Context,? extends C> createFn) Returns a fluent-API builder with which you can create an unbounded stream source for a Jet pipeline.
<S_NEW> ServiceFactory<C,S_NEW>	ServiceFactory.withCreateServiceFn(BiFunctionEx<? super Processor.Context,? super C,? extends S_NEW> createServiceFn) Returns a copy of this ServiceFactory with the given createService function.

Uses of Processor.Context in com.hazelcast.jet.pipeline.test

Methods in com.hazelcast.jet.pipeline.test with parameters of type Processor.Context

Modifier and Type	Method and Description
protected void	ParallelStreamP.init(Processor.Context context)
protected void	ParallelBatchP.init(Processor.Context context)
protected void	LongStreamSourceP.init(Processor.Context context)