public class RemoteJobRepository extends AbstractRemoteDao implements JobRepository
| Constructor and Description |
|---|
RemoteJobRepository() |
RemoteJobRepository(org.springframework.yarn.integration.ip.mind.AppmasterMindScOperations appmasterScOperations) |
| Modifier and Type | Method and Description |
|---|---|
void |
add(StepExecution stepExecution) |
void |
addAll(Collection<StepExecution> stepExecutions) |
JobExecution |
createJobExecution(JobInstance jobInstance,
JobParameters jobParameters,
String jobConfigurationLocation) |
JobExecution |
createJobExecution(String jobName,
JobParameters jobParameters) |
JobInstance |
createJobInstance(String jobName,
JobParameters jobParameters) |
JobExecution |
getLastJobExecution(String jobName,
JobParameters jobParameters) |
StepExecution |
getLastStepExecution(JobInstance jobInstance,
String stepName) |
int |
getStepExecutionCount(JobInstance jobInstance,
String stepName) |
boolean |
isJobInstanceExists(String jobName,
JobParameters jobParameters) |
void |
update(JobExecution jobExecution) |
void |
update(StepExecution stepExecution) |
void |
updateExecutionContext(JobExecution jobExecution) |
void |
updateExecutionContext(StepExecution stepExecution) |
checkResponseMayThrow, convertException, getAppmasterScOperations, setAppmasterScOperationspublic RemoteJobRepository()
public RemoteJobRepository(org.springframework.yarn.integration.ip.mind.AppmasterMindScOperations appmasterScOperations)
public boolean isJobInstanceExists(String jobName, JobParameters jobParameters)
isJobInstanceExists in interface JobRepositorypublic JobExecution createJobExecution(String jobName, JobParameters jobParameters) throws JobExecutionAlreadyRunningException, JobRestartException, JobInstanceAlreadyCompleteException
createJobExecution in interface JobRepositoryJobExecutionAlreadyRunningExceptionJobRestartExceptionJobInstanceAlreadyCompleteExceptionpublic void update(JobExecution jobExecution)
update in interface JobRepositorypublic void add(StepExecution stepExecution)
add in interface JobRepositorypublic void addAll(Collection<StepExecution> stepExecutions)
addAll in interface JobRepositorypublic void update(StepExecution stepExecution)
update in interface JobRepositorypublic void updateExecutionContext(StepExecution stepExecution)
updateExecutionContext in interface JobRepositorypublic void updateExecutionContext(JobExecution jobExecution)
updateExecutionContext in interface JobRepositorypublic StepExecution getLastStepExecution(JobInstance jobInstance, String stepName)
getLastStepExecution in interface JobRepositorypublic int getStepExecutionCount(JobInstance jobInstance, String stepName)
getStepExecutionCount in interface JobRepositorypublic JobExecution getLastJobExecution(String jobName, JobParameters jobParameters)
getLastJobExecution in interface JobRepositorypublic JobInstance createJobInstance(String jobName, JobParameters jobParameters)
createJobInstance in interface JobRepositorypublic JobExecution createJobExecution(JobInstance jobInstance, JobParameters jobParameters, String jobConfigurationLocation)
createJobExecution in interface JobRepository