org.springframework.yarn.batch.repository
Class RemoteJobExecutionDao

java.lang.Object
  extended by org.springframework.yarn.batch.repository.AbstractRemoteDao
      extended by 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

Constructor Summary
RemoteJobExecutionDao()
           
RemoteJobExecutionDao(org.springframework.yarn.integration.ip.mind.AppmasterMindScOperations appmasterScOperations)
           
 
Method Summary
 List<JobExecution> findJobExecutions(JobInstance jobInstance)
           
 Set<JobExecution> findRunningJobExecutions(String jobName)
           
 JobExecution getJobExecution(Long executionId)
           
 JobExecution getLastJobExecution(JobInstance jobInstance)
           
 void saveJobExecution(JobExecution jobExecution)
           
 void synchronizeStatus(JobExecution jobExecution)
           
 void updateJobExecution(JobExecution jobExecution)
           
 
Methods inherited from class org.springframework.yarn.batch.repository.AbstractRemoteDao
checkResponseMayThrow, convertException, getAppmasterScOperations, setAppmasterScOperations
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Constructor Detail

RemoteJobExecutionDao

public RemoteJobExecutionDao()

RemoteJobExecutionDao

public RemoteJobExecutionDao(org.springframework.yarn.integration.ip.mind.AppmasterMindScOperations appmasterScOperations)
Method Detail

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