ProcessorMetaSupplier.Context (Hazelcast Root 5.0.2 API)

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

All Methods Instance Methods Abstract Methods Default Methods Deprecated Methods
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.

- Method Detail
  - hazelcastInstance
```
@Nonnull
HazelcastInstance hazelcastInstance()
```
    Returns the current Hazelcast instance.
    
    Since:
    
    5.0
  - jetInstance
```
@Nonnull
 @Deprecated
JetInstance jetInstance()
```
    Deprecated. Use hazelcastInstance().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
```
@Nonnull
JobConfig jobConfig()
```
    Returns the JobConfig.
  - totalParallelism
```
int totalParallelism()
```
    Returns the total number of Processors that will be created across the cluster. This number remains stable for entire job execution. It is equal to memberCount() * localParallelism().
  - localParallelism
```
int localParallelism()
```
    Returns the number of processors that each 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.
  - 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
```
@Nonnull
String vertexName()
```
    Returns the name of the associated vertex.
  - logger
```
@Nonnull
ILogger logger()
```
    Returns a logger for the associated ProcessorMetaSupplier.
  - 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 single Processor.
  - isLightJob
```
boolean isLightJob()
```
    Returns if this job runs as a light job, see JetService.newLightJob(Pipeline).
  - partitionAssignment
```
Map<Address,int[]> 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.
  - classLoader
```
ClassLoader classLoader()
```
    Processor classloader configured via JobConfig.addCustomClasspath(String, String)
    
    Returns:
    
    processor classloader, null if no custom classpath elements are configured

Interface ProcessorMetaSupplier.Context

Method Summary

Method Detail

hazelcastInstance

jetInstance

jobId

executionId

jobConfig

totalParallelism

localParallelism

memberCount

vertexName

logger

snapshottingEnabled

processingGuarantee

maxProcessorAccumulatedRecords

isLightJob

partitionAssignment

classLoader