org.springframework.yarn.batch.repository
Class RemoteJobExecutionDao
java.lang.Object
org.springframework.yarn.batch.repository.AbstractRemoteDao
org.springframework.yarn.batch.repository.RemoteJobExecutionDao
- All Implemented Interfaces:
- JobExecutionDao
public class RemoteJobExecutionDao
- extends AbstractRemoteDao
- implements JobExecutionDao
Proxy implementation of JobExecutionDao. Passes dao
methods to a remote repository via service calls using
RpcMessage messages.
- Author:
- Janne Valkealahti
| Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
RemoteJobExecutionDao
public RemoteJobExecutionDao()
RemoteJobExecutionDao
public RemoteJobExecutionDao(org.springframework.yarn.integration.ip.mind.AppmasterMindScOperations appmasterScOperations)
saveJobExecution
public void saveJobExecution(JobExecution jobExecution)
- Specified by:
saveJobExecution in interface JobExecutionDao
updateJobExecution
public void updateJobExecution(JobExecution jobExecution)
- Specified by:
updateJobExecution in interface JobExecutionDao
findJobExecutions
public List<JobExecution> findJobExecutions(JobInstance jobInstance)
- Specified by:
findJobExecutions in interface JobExecutionDao
getLastJobExecution
public JobExecution getLastJobExecution(JobInstance jobInstance)
- Specified by:
getLastJobExecution in interface JobExecutionDao
findRunningJobExecutions
public Set<JobExecution> findRunningJobExecutions(String jobName)
- Specified by:
findRunningJobExecutions in interface JobExecutionDao
getJobExecution
public JobExecution getJobExecution(Long executionId)
- Specified by:
getJobExecution in interface JobExecutionDao
synchronizeStatus
public void synchronizeStatus(JobExecution jobExecution)
- Specified by:
synchronizeStatus in interface JobExecutionDao