org.springframework.yarn.batch.repository
Class RemoteStepExecutionDao

java.lang.Object
  org.springframework.yarn.batch.repository.AbstractRemoteDao
      org.springframework.yarn.batch.repository.RemoteStepExecutionDao

All Implemented Interfaces:

org.springframework.batch.core.repository.dao.StepExecutionDao

public class RemoteStepExecutionDao
extends AbstractRemoteDao
implements org.springframework.batch.core.repository.dao.StepExecutionDao

Proxy implementation of StepExecutionDao. Passes dao methods to a remote repository via service calls using RpcMessage messages.

Author:

Janne Valkealahti

Constructor Summary

RemoteStepExecutionDao()

RemoteStepExecutionDao(AppmasterMindScOperations appmasterScOperations)

Method Summary

void	addStepExecutions(org.springframework.batch.core.JobExecution jobExecution)
org.springframework.batch.core.StepExecution	getStepExecution(org.springframework.batch.core.JobExecution jobExecution, java.lang.Long stepExecutionId)
void	saveStepExecution(org.springframework.batch.core.StepExecution stepExecution)
void	updateStepExecution(org.springframework.batch.core.StepExecution stepExecution)

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

RemoteStepExecutionDao

public RemoteStepExecutionDao()

RemoteStepExecutionDao

public RemoteStepExecutionDao(AppmasterMindScOperations appmasterScOperations)

Method Detail

saveStepExecution

public void saveStepExecution(org.springframework.batch.core.StepExecution stepExecution)

Specified by:

saveStepExecution in interface org.springframework.batch.core.repository.dao.StepExecutionDao

updateStepExecution

public void updateStepExecution(org.springframework.batch.core.StepExecution stepExecution)

Specified by:

updateStepExecution in interface org.springframework.batch.core.repository.dao.StepExecutionDao

getStepExecution

public org.springframework.batch.core.StepExecution getStepExecution(org.springframework.batch.core.JobExecution jobExecution,
                                                                     java.lang.Long stepExecutionId)

Specified by:

getStepExecution in interface org.springframework.batch.core.repository.dao.StepExecutionDao

addStepExecutions

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

Specified by:

addStepExecutions in interface org.springframework.batch.core.repository.dao.StepExecutionDao