public interface JobStateService extends JobMetricsService
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.
|
getNumActiveJobs, getUsedMemory
void init(java.lang.String jobId)
jobId
- job idvoid schedule(java.lang.String jobId, JobRequest jobRequest, Cluster cluster, Command command, java.util.List<Application> applications, int memory)
jobId
- job idjobRequest
- job requestcluster
- cluster for the job request based on the tags specifiedcommand
- command for the job request based on command tags and cluster chosenapplications
- applications to use based on the command that was selectedmemory
- job memoryvoid done(java.lang.String jobId) throws GenieException
jobId
- job idGenieException
- on unrecoverable errorboolean jobExists(java.lang.String jobId)
jobId
- job id