public static interface ProcessorMetaSupplier.Context
Modifier and Type | Method and Description |
---|---|
ClassLoader |
classLoader()
Processor classloader configured via
JobConfig.addCustomClasspath(String, String) |
long |
executionId()
Returns the job execution ID.
|
HazelcastInstance |
hazelcastInstance()
Returns the current Hazelcast instance.
|
boolean |
isLightJob()
Returns if this job runs as a light job, see
JetService.newLightJob(Pipeline) . |
JetInstance |
jetInstance()
Deprecated.
Use
hazelcastInstance().getJet() instead. |
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 . |
long |
maxProcessorAccumulatedRecords()
Returns the maximum number of records that can be accumulated by any
single
Processor . |
int |
memberCount()
Returns the number of members running this job.
|
Map<Address,int[]> |
partitionAssignment()
Returns the partition assignment used by 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 of
Processor s that will be created
across the cluster. |
String |
vertexName()
Returns the name of the associated vertex.
|
@Nonnull HazelcastInstance hazelcastInstance()
@Nonnull @Deprecated JetInstance jetInstance()
hazelcastInstance().getJet()
instead.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.
default boolean snapshottingEnabled()
ProcessingGuarantee processingGuarantee()
long maxProcessorAccumulatedRecords()
Processor
.boolean isLightJob()
JetService.newLightJob(Pipeline)
.Map<Address,int[]> partitionAssignment()
ClassLoader classLoader()
JobConfig.addCustomClasspath(String, String)
Copyright © 2022 Hazelcast, Inc.. All rights reserved.