org.springframework.yarn.batch.repository
Class RemoteJobRepository
java.lang.Object
org.springframework.yarn.batch.repository.AbstractRemoteDao
org.springframework.yarn.batch.repository.RemoteJobRepository
- All Implemented Interfaces:
- JobRepository
public class RemoteJobRepository
- extends AbstractRemoteDao
- implements JobRepository
| Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
RemoteJobRepository
public RemoteJobRepository()
RemoteJobRepository
public RemoteJobRepository(org.springframework.yarn.integration.ip.mind.AppmasterMindScOperations appmasterScOperations)
isJobInstanceExists
public boolean isJobInstanceExists(String jobName,
JobParameters jobParameters)
- Specified by:
isJobInstanceExists in interface JobRepository
createJobExecution
public JobExecution createJobExecution(String jobName,
JobParameters jobParameters)
throws JobExecutionAlreadyRunningException,
JobRestartException,
JobInstanceAlreadyCompleteException
- Specified by:
createJobExecution in interface JobRepository
- Throws:
JobExecutionAlreadyRunningException
JobRestartException
JobInstanceAlreadyCompleteException
update
public void update(JobExecution jobExecution)
- Specified by:
update in interface JobRepository
add
public void add(StepExecution stepExecution)
- Specified by:
add in interface JobRepository
addAll
public void addAll(Collection<StepExecution> stepExecutions)
- Specified by:
addAll in interface JobRepository
update
public void update(StepExecution stepExecution)
- Specified by:
update in interface JobRepository
updateExecutionContext
public void updateExecutionContext(StepExecution stepExecution)
- Specified by:
updateExecutionContext in interface JobRepository
updateExecutionContext
public void updateExecutionContext(JobExecution jobExecution)
- Specified by:
updateExecutionContext in interface JobRepository
getLastStepExecution
public StepExecution getLastStepExecution(JobInstance jobInstance,
String stepName)
- Specified by:
getLastStepExecution in interface JobRepository
getStepExecutionCount
public int getStepExecutionCount(JobInstance jobInstance,
String stepName)
- Specified by:
getStepExecutionCount in interface JobRepository
getLastJobExecution
public JobExecution getLastJobExecution(String jobName,
JobParameters jobParameters)
- Specified by:
getLastJobExecution in interface JobRepository
createJobInstance
public JobInstance createJobInstance(String jobName,
JobParameters jobParameters)
- Specified by:
createJobInstance in interface JobRepository
createJobExecution
public JobExecution createJobExecution(JobInstance jobInstance,
JobParameters jobParameters,
String jobConfigurationLocation)
- Specified by:
createJobExecution in interface JobRepository