com.hazelcast.jet.core

Interface ProcessorMetaSupplier.Context

All Known Subinterfaces:

Processor.Context, ProcessorSupplier.Context

All Known Implementing Classes:

TestProcessorContext, TestProcessorMetaSupplierContext, TestProcessorSupplierContext

Enclosing interface:

ProcessorMetaSupplier

public static interface ProcessorMetaSupplier.Context

Context passed to the meta-supplier at init time on the member that received a job request from the client.

Method Summary

Modifier and Type	Method and Description
JetInstance	jetInstance() Returns the current Jet instance.
int	localParallelism() Returns the number of processors that each ProcessorSupplier will be asked to create once deserialized on each member.
ILogger	logger() Returns a logger for the associated ProcessorMetaSupplier.
int	totalParallelism() Returns the total number of Processors that will be created across the cluster.
String	vertexName() Returns the name of the associated vertex.

Method Detail

jetInstance

@Nonnull
JetInstance jetInstance()

Returns the current Jet instance.

totalParallelism

int totalParallelism()

Returns the total number of Processors that will be created across the cluster. This number remains stable for entire job execution.

localParallelism

int localParallelism()

Returns the number of processors that each ProcessorSupplier will be asked to create once deserialized on each member. All members have equal local parallelism; dividing totalParallelism() by local parallelism gives you the participating member count. The count doesn't change unless the job restarts.

vertexName

@Nonnull
String vertexName()

Returns the name of the associated vertex.

logger

@Nonnull
ILogger logger()

Returns a logger for the associated ProcessorMetaSupplier.