com.hazelcast.jet.core

Interface Processor.Context

All Superinterfaces:

ProcessorMetaSupplier.Context, ProcessorSupplier.Context

All Known Implementing Classes:

TestProcessorContext

Enclosing interface:

Processor

public static interface Processor.Context
extends ProcessorSupplier.Context

Context passed to the processor in the init() call.

Method Summary

Modifier and Type	Method and Description
int	globalProcessorIndex() Returns the index of the processor among all the processors created for this vertex on all nodes: its unique cluster-wide index.
ILogger	logger() Return a logger for the processor
ProcessingGuarantee	processingGuarantee() Returns the guarantee for current job.
default boolean	snapshottingEnabled() Returns true, if snapshots will be saved for this job.

Methods inherited from interface com.hazelcast.jet.core.ProcessorMetaSupplier.Context

jetInstance, localParallelism, totalParallelism, vertexName

Method Detail

logger

@Nonnull
ILogger logger()

Return a logger for the processor

Specified by:

logger in interface ProcessorMetaSupplier.Context

Specified by:

logger in interface ProcessorSupplier.Context

globalProcessorIndex

int globalProcessorIndex()

Returns the index of the processor among all the processors created for this vertex on all nodes: its unique cluster-wide index.

The index values will be in the range of [0...totalParallelism-1].

snapshottingEnabled

default boolean snapshottingEnabled()

Returns true, if snapshots will be saved for this job.

processingGuarantee

ProcessingGuarantee processingGuarantee()

Returns the guarantee for current job.