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
|
ProcessingGuarantee |
processingGuarantee()
Returns the guarantee for current job.
|
default boolean |
snapshottingEnabled()
Returns true, if snapshots will be saved for this job.
|
memberIndex
executionId, jetInstance, jobConfig, jobId, localParallelism, memberCount, 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]
.
default boolean snapshottingEnabled()
ProcessingGuarantee processingGuarantee()
Copyright © 2018 Hazelcast, Inc.. All rights reserved.