Package com.hazelcast.jet.core
Interface ProcessorMetaSupplier.Context
- All Known Subinterfaces:
Processor.Context
,ProcessorSupplier.Context
- All Known Implementing Classes:
TestProcessorContext
,TestProcessorMetaSupplierContext
,TestProcessorSupplierContext
- 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.
- Since:
- 3.0
-
Method Summary
Modifier and Type Method Description long
executionId()
Returns the job execution ID.JetInstance
jetInstance()
Returns the current Jet instance.JobConfig
jobConfig()
Returns theJobConfig
.long
jobId()
Returns the job ID.int
localParallelism()
Returns the number of processors that eachProcessorSupplier
will be asked to create once deserialized on each member.ILogger
logger()
Returns a logger for the associatedProcessorMetaSupplier
.int
memberCount()
Returns the number of members running this job.ProcessingGuarantee
processingGuarantee()
Returns the guarantee for current job.default boolean
snapshottingEnabled()
Returns true, if snapshots will be saved for this job.int
totalParallelism()
Returns the total number ofProcessor
s that will be created across the cluster.String
vertexName()
Returns the name of the associated vertex.
-
Method Details
-
jetInstance
Returns the current Jet instance. -
jobId
long jobId()Returns the job ID. Job id is unique for job submission and doesn't change when the job restarts. It's also unique for all running and archived jobs. -
executionId
long executionId()Returns the job execution ID. It's unique for one execution, but changes when the job restarts. -
jobConfig
Returns theJobConfig
. -
totalParallelism
int totalParallelism()Returns the total number ofProcessor
s that will be created across the cluster. This number remains stable for entire job execution. It is equal tomemberCount()
*localParallelism()
. -
localParallelism
int localParallelism()Returns the number of processors that eachProcessorSupplier
will be asked to create once deserialized on each member. All members have equal local parallelism. The count doesn't change unless the job restarts. -
memberCount
int memberCount()Returns the number of members running this job.Note that the value might be lower than current member count if members were added after the job started. The count doesn't change unless the job restarts.
-
vertexName
Returns the name of the associated vertex. -
logger
Returns a logger for the associatedProcessorMetaSupplier
. -
snapshottingEnabled
default boolean snapshottingEnabled()Returns true, if snapshots will be saved for this job. -
processingGuarantee
ProcessingGuarantee processingGuarantee()Returns the guarantee for current job.
-