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:

org.springframework.batch.core.repository.dao.JobExecutionDao

public class RemoteJobExecutionDao
extends AbstractRemoteDao
implements org.springframework.batch.core.repository.dao.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(AppmasterMindScOperations appmasterScOperations)

Method Summary

java.util.List<org.springframework.batch.core.JobExecution>	findJobExecutions(org.springframework.batch.core.JobInstance jobInstance)
java.util.Set<org.springframework.batch.core.JobExecution>	findRunningJobExecutions(java.lang.String jobName)
org.springframework.batch.core.JobExecution	getJobExecution(java.lang.Long executionId)
org.springframework.batch.core.JobExecution	getLastJobExecution(org.springframework.batch.core.JobInstance jobInstance)
void	saveJobExecution(org.springframework.batch.core.JobExecution jobExecution)
void	synchronizeStatus(org.springframework.batch.core.JobExecution jobExecution)
void	updateJobExecution(org.springframework.batch.core.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(AppmasterMindScOperations appmasterScOperations)

Method Detail

saveJobExecution

public void saveJobExecution(org.springframework.batch.core.JobExecution jobExecution)

Specified by:

saveJobExecution in interface org.springframework.batch.core.repository.dao.JobExecutionDao

updateJobExecution

public void updateJobExecution(org.springframework.batch.core.JobExecution jobExecution)

Specified by:

updateJobExecution in interface org.springframework.batch.core.repository.dao.JobExecutionDao

findJobExecutions

public java.util.List<org.springframework.batch.core.JobExecution> findJobExecutions(org.springframework.batch.core.JobInstance jobInstance)

Specified by:

findJobExecutions in interface org.springframework.batch.core.repository.dao.JobExecutionDao

getLastJobExecution

public org.springframework.batch.core.JobExecution getLastJobExecution(org.springframework.batch.core.JobInstance jobInstance)

Specified by:

getLastJobExecution in interface org.springframework.batch.core.repository.dao.JobExecutionDao

findRunningJobExecutions

public java.util.Set<org.springframework.batch.core.JobExecution> findRunningJobExecutions(java.lang.String jobName)

Specified by:

findRunningJobExecutions in interface org.springframework.batch.core.repository.dao.JobExecutionDao

getJobExecution

public org.springframework.batch.core.JobExecution getJobExecution(java.lang.Long executionId)

Specified by:

getJobExecution in interface org.springframework.batch.core.repository.dao.JobExecutionDao

synchronizeStatus

public void synchronizeStatus(org.springframework.batch.core.JobExecution jobExecution)

Specified by:

synchronizeStatus in interface org.springframework.batch.core.repository.dao.JobExecutionDao