public static interface ProcessorSupplier.Context extends ProcessorMetaSupplier.Context
init()
call.Modifier and Type | Method and Description |
---|---|
File |
attachedDirectory(String id)
Uses the supplied ID to look up a directory you attached to the current
Jet job.
|
File |
attachedFile(String id)
Uses the supplied ID to look up a file you attached to the current Jet
job.
|
ILogger |
logger()
Returns a logger for the associated
ProcessorSupplier . |
ManagedContext |
managedContext()
Returns
ManagedContext associated with this job. |
int |
memberIndex()
Returns the index of the member among all the members that run this
job: it's a unique cluster-wide index.
|
default int[] |
memberPartitions()
Returns the partitions from
ProcessorMetaSupplier.Context.partitionAssignment() pertaining to
this member. |
File |
recreateAttachedDirectory(String id)
Behaves like
attachedDirectory(java.lang.String) , but if the directory already
exists, it deletes and recreates all its contents. |
File |
recreateAttachedFile(String id)
Behaves like
attachedFile(java.lang.String) , but if the file already exists, it
deletes and recreates it. |
classLoader, executionId, hazelcastInstance, isLightJob, jetInstance, jobConfig, jobId, localParallelism, maxProcessorAccumulatedRecords, memberCount, partitionAssignment, processingGuarantee, snapshottingEnabled, totalParallelism, vertexName
@Nonnull ILogger logger()
ProcessorSupplier
.logger
in interface ProcessorMetaSupplier.Context
int memberIndex()
The value is in the range [0...memberCount-1]
.
@Nonnull File attachedDirectory(@Nonnull String id)
id
- the ID you used in a previous JobConfig.attachDirectory(java.net.URL)
call@Nonnull File recreateAttachedDirectory(@Nonnull String id)
attachedDirectory(java.lang.String)
, but if the directory already
exists, it deletes and recreates all its contents.@Nonnull File attachedFile(@Nonnull String id)
id
- the ID you used in a previous JobConfig.attachFile(java.net.URL)
call@Nonnull File recreateAttachedFile(@Nonnull String id)
attachedFile(java.lang.String)
, but if the file already exists, it
deletes and recreates it.@Nonnull ManagedContext managedContext()
ManagedContext
associated with this job.@Nonnull default int[] memberPartitions()
ProcessorMetaSupplier.Context.partitionAssignment()
pertaining to
this member. The returned list can be empty.Copyright © 2023 Hazelcast, Inc.. All rights reserved.