Interface ClusterTaskScheduler

    • Method Detail

      • getSchedulerName

        String getSchedulerName()
        Get the scheduler name.
        Returns:
        the name of the scheduler
      • configure

        void configure​(Settings settings)
                throws EoulsanException
        Configure the scheduler.
        Parameters:
        settings - Eoulsan settings
        Throws:
        EoulsanException - if an error occurs while configuring the scheduler
      • submitJob

        String submitJob​(String jobName,
                         List<String> jobCommand,
                         File jobDirectory,
                         int taskId,
                         int requiredMemory,
                         int requiredProcessors)
                  throws IOException
        Submit a job.
        Parameters:
        jobName - job name
        jobCommand - job command
        jobDirectory - job directory
        taskId - task id
        requiredMemory - required memory
        requiredProcessors - required processors
        Returns:
        a String with the id of the submitted job
        Throws:
        IOException - if an error occurs while submitting job
      • stopJob

        void stopJob​(String jobId)
              throws IOException
        Stop a job.
        Parameters:
        jobId - job id
        Throws:
        IOException - if an error occurs while stopping the job
      • cleanupJob

        void cleanupJob​(String jobId)
                 throws IOException
        Cleanup after a job.
        Parameters:
        jobId - job id
        Throws:
        IOException - if an error occurs while cleanup