com.hazelcast.jet.core

Interface ProcessorMetaSupplier.Context

All Known Implementing Classes:

TestProcessorMetaSupplierContext

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.
com.hazelcast.logging.ILogger	logger() Returns a logger for the associated ProcessorSupplier.
int	totalParallelism() Returns the total number of Processors that will be created across the cluster.

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.

localParallelism

int localParallelism()

Returns the number of processors that each ProcessorSupplier will be asked to create once deserialized on each member.

logger

@Nonnull
com.hazelcast.logging.ILogger logger()

Returns a logger for the associated ProcessorSupplier.