public class XStreamJobRepository extends Object implements JobRepository
Constructor and Description |
---|
XStreamJobRepository(File workingDir,
int maxHistory) |
Modifier and Type | Method and Description |
---|---|
String |
addJob(JobSpec spec) |
protected File |
generateFilePath(String jobId) |
JobSpec |
getJobById(String jobId) |
String |
getStatus(JobSpec spec) |
boolean |
jobFinished(JobSpec spec) |
void |
removeJob(JobSpec spec) |
void |
updateJob(JobSpec spec) |
public XStreamJobRepository(File workingDir, int maxHistory)
public String addJob(JobSpec spec) throws JobRepositoryException
addJob
in interface JobRepository
JobRepositoryException
public JobSpec getJobById(String jobId) throws JobRepositoryException
getJobById
in interface JobRepository
JobRepositoryException
public String getStatus(JobSpec spec) throws JobRepositoryException
getStatus
in interface JobRepository
JobRepositoryException
public boolean jobFinished(JobSpec spec) throws JobRepositoryException
jobFinished
in interface JobRepository
JobRepositoryException
public void removeJob(JobSpec spec) throws JobRepositoryException
removeJob
in interface JobRepository
JobRepositoryException
public void updateJob(JobSpec spec) throws JobRepositoryException
updateJob
in interface JobRepository
JobRepositoryException
Copyright © 1999–2017 Apache OODT. All rights reserved.