public static interface ProcessorMetaSupplier.Context
Modifier and Type | Method and Description |
---|---|
long |
executionId()
Returns the job execution ID.
|
JetInstance |
jetInstance()
Returns the current Jet instance.
|
JobConfig |
jobConfig()
Returns the
JobConfig . |
long |
jobId()
Returns the job ID.
|
int |
localParallelism()
Returns the number of processors that each
ProcessorSupplier
will be asked to create once deserialized on each member. |
ILogger |
logger()
Returns a logger for the associated
ProcessorMetaSupplier . |
int |
memberCount()
Returns the number of members running this job.
|
int |
totalParallelism()
Returns the total number of
Processor s that will be created
across the cluster. |
String |
vertexName()
Returns the name of the associated vertex.
|
@Nonnull JetInstance jetInstance()
long jobId()
long executionId()
int totalParallelism()
Processor
s that will be created
across the cluster. This number remains stable for entire job
execution. It is equal to memberCount()
* localParallelism()
.int localParallelism()
ProcessorSupplier
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.int memberCount()
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.
Copyright © 2018 Hazelcast, Inc.. All rights reserved.