public static interface Processor.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: its unique cluster-wide index.
|
JetInstance |
jetInstance()
Returns the current Jet instance
|
com.hazelcast.logging.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.
|
String |
vertexName()
Returns the name of the vertex associated with this processor.
|
@Nonnull JetInstance jetInstance()
@Nonnull com.hazelcast.logging.ILogger logger()
int globalProcessorIndex()
@Nonnull String vertexName()
default boolean snapshottingEnabled()
ProcessingGuarantee processingGuarantee()
Copyright © 2017 Hazelcast, Inc.. All Rights Reserved.