public static interface Processor.Context extends ProcessorSupplier.Context
init()
call.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: it's a unique cluster-wide index.
|
int |
localProcessorIndex()
Returns the index of the processor among all the processors created for
this vertex on a single node: it's a unique node-wide index.
|
ILogger |
logger()
Return a logger for the processor
|
default int[] |
processorPartitions()
Returns the slice of partitions for this processor.
|
attachedDirectory, attachedFile, managedContext, memberIndex, memberPartitions, recreateAttachedDirectory, recreateAttachedFile
classLoader, executionId, hazelcastInstance, isLightJob, jetInstance, jobConfig, jobId, localParallelism, maxProcessorAccumulatedRecords, memberCount, partitionAssignment, processingGuarantee, snapshottingEnabled, totalParallelism, vertexName
@Nonnull ILogger logger()
logger
in interface ProcessorMetaSupplier.Context
logger
in interface ProcessorSupplier.Context
int localProcessorIndex()
The value is in the range [0...localParallelism-1]
.
int globalProcessorIndex()
The value is in the range [0...totalParallelism-1]
. For
example if there are 2 members in the cluster and local parallelism is 4, the processors on the
1st cluster member will have indexes 0..3 and on the second member
they will have indexes 4..7.
default int[] processorPartitions()
ProcessorSupplier.Context.memberPartitions()
according to the ProcessorMetaSupplier.Context.localParallelism()
and localProcessorIndex()
.Copyright © 2023 Hazelcast, Inc.. All rights reserved.