Package org.apache.ignite.compute

Interface JobExecutionContext

public interface JobExecutionContext
Context of the ComputeJob execution.

  • Method Details

    • ignite

      Ignite ignite()
      Ignite API entry point.
      Returns:
      Ignite instance.

    • isCancelled

      boolean isCancelled()
      Flag indicating whether the job was cancelled.
      Returns:
      true when the job was cancelled.

    • partition

      @Nullable @Nullable Partition partition()
      Partition associated with this job. Not a null only when BroadcastJobTarget.table(String) target is used for submitting jobs. In this case, the partition is local on a node executing the job.
      Returns:
      Partition associated with this job.

    • cancellationToken

      CancellationToken cancellationToken()
      Cancellation token that is canceled when the job is canceled. Can be passed to SQL queries and other operations that accept CancellationToken to propagate cancellation from the job to those operations.
      Returns:
      Cancellation token associated with this job.

    • deploymentUnits

      Collection<DeploymentUnitInfo> deploymentUnits()
      Collection of deployment units associated with this job execution.
      Returns:
      Collection of deployment units for this job execution.