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:
- Jet 3.0
-
Method Summary
Modifier and TypeMethodDescriptionvoid
checkPermission
(Permission permission) Check if the current Subject has the given permission granted (or implied).Processor classloader configured viaJobConfig.addCustomClasspath(String, String)
A service to accessDataConnection
s in processors.long
Returns the job execution ID.Returns the current Hazelcast instance.boolean
Returns if this job runs as a light job, seeJetService.newLightJob(Pipeline)
.Deprecated.Returns theJobConfig
.long
jobId()
Returns the job ID.int
Returns the number of processors that eachProcessorSupplier
will be asked to create once deserialized on each member.logger()
Returns a logger for the associatedProcessorMetaSupplier
.long
Returns the maximum number of records that can be accumulated by any singleProcessor
.int
Returns the number of members running this job.Returns the partition assignment used by this job.Returns the guarantee for current job.default boolean
Returns true, if snapshots will be saved for this job.int
Returns the total number ofProcessor
s that will be created across the cluster.Returns the name of the associated vertex.
-
Method Details
-
hazelcastInstance
Returns the current Hazelcast instance.- Since:
- 5.0
-
jetInstance
Deprecated.UsehazelcastInstance().getJet()
instead.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. -
maxProcessorAccumulatedRecords
long maxProcessorAccumulatedRecords()Returns the maximum number of records that can be accumulated by any singleProcessor
. The returned value is strictly positive (>=1). -
isLightJob
boolean isLightJob()Returns if this job runs as a light job, seeJetService.newLightJob(Pipeline)
. -
partitionAssignment
Returns the partition assignment used by this job. This is the assignment partitioned edges will use and the assignment processors dealing with Hazelcast data structures should use. Each mapped partitions id array must be sorted. -
classLoader
ClassLoader classLoader()Processor classloader configured viaJobConfig.addCustomClasspath(String, String)
- Returns:
- processor classloader, null if no custom classpath elements are configured
-
dataConnectionService
DataConnectionService dataConnectionService()A service to accessDataConnection
s in processors.- Since:
- 5.3
-
checkPermission
Check if the current Subject has the given permission granted (or implied).- Parameters:
permission
- Permission to be checked- Throws:
AccessControlException
- when the security is enabled and the checked permission is not implied for the currentSubject
-
hazelcastInstance().getJet()
instead.