Interface JobContext


  • public interface JobContext
    Context available to job.
    • Method Detail

      • getDistributedExecutor

        DistributedExecutorService getDistributedExecutor()
        Returns an executor service for performing work within the job. Starts the first time it is used. Shuts down when the job is shutdown.
        Returns:
        the executor service.
      • ensureJobStorageManager

        StorageManager ensureJobStorageManager()
        Returns a storage manager for storing temporary files. Allocated upon job start, auto-released on job shutdown Calling this method forces allocation of nodes in the cluster so this should not be invoked within JobCallable.init(JobContext).
        Returns:
        the storage manager
      • releaseStorage

        void releaseStorage​(FileClient fileClient,
                            StoragePlanner storagePlanner)
        Releases all storage for this storage manager that was allocated by the given planner. This call is ignored if a storage manager was never created
        Parameters:
        fileClient - the file client
        storagePlanner - the storage planner
      • getFileClient

        FileClient getFileClient()
        Returns the file client to be used within this context
        Returns:
        the file client