Interface ProcessorMetaSupplier.Context

    • Method Detail

      • hazelcastInstance

        HazelcastInstance hazelcastInstance()
        Returns the current Hazelcast instance.
      • jetInstance

        JetInstance jetInstance()
        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.
      • 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

        java.lang.String vertexName()
        Returns the name of the associated vertex.
      • logger

        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. The returned value is strictly positive (>=1).
      • partitionAssignment

        java.util.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. Each mapped partitions id array must be sorted.
      • checkPermission

        void checkPermission​(@Nonnull
        Check if the current Subject has the given permission granted (or implied).
        permission - Permission to be checked
        Throws: - when the security is enabled and the checked permission is not implied for the current Subject