com.netflix.genie.core.services

Interface JobStateService

All Superinterfaces:

JobMetricsService

All Known Implementing Classes:

JobMonitoringCoordinator, JobStateServiceImpl

public interface JobStateService
extends JobMetricsService

A service which defines the three basic stages of a job.

Since:

3.0.0

Method Summary

Modifier and Type	Method and Description
void	done(java.lang.String jobId) Called when the job is done.
void	init(java.lang.String jobId) Initialize the job.
boolean	jobExists(java.lang.String jobId) Returns true if the job exists locally.
void	schedule(java.lang.String jobId, JobRequest jobRequest, Cluster cluster, Command command, java.util.List<Application> applications, int memory) Schedules the job.

Methods inherited from interface com.netflix.genie.core.services.JobMetricsService

getNumActiveJobs, getUsedMemory

Method Detail

init

void init(java.lang.String jobId)

Initialize the job.

Parameters:

jobId - job id

schedule

void schedule(java.lang.String jobId,
              JobRequest jobRequest,
              Cluster cluster,
              Command command,
              java.util.List<Application> applications,
              int memory)

Schedules the job.

Parameters:

jobId - job id

jobRequest - job request

cluster - cluster for the job request based on the tags specified

command - command for the job request based on command tags and cluster chosen

applications - applications to use based on the command that was selected

memory - job memory

done

void done(java.lang.String jobId)
   throws GenieException

Called when the job is done.

Parameters:

jobId - job id

Throws:

GenieException - on unrecoverable error

jobExists

boolean jobExists(java.lang.String jobId)

Returns true if the job exists locally.

Parameters:

jobId - job id

Returns:

true if job exists