org.springframework.yarn.batch.repository
Class RemoteStepExecutionDao

java.lang.Object
  extended by org.springframework.yarn.batch.repository.AbstractRemoteDao
      extended by org.springframework.yarn.batch.repository.RemoteStepExecutionDao
All Implemented Interfaces:
StepExecutionDao

public class RemoteStepExecutionDao
extends AbstractRemoteDao
implements 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(org.springframework.yarn.integration.ip.mind.AppmasterMindScOperations appmasterScOperations)
           
 
Method Summary
 void addStepExecutions(JobExecution jobExecution)
           
 StepExecution getStepExecution(JobExecution jobExecution, Long stepExecutionId)
           
 void saveStepExecution(StepExecution stepExecution)
           
 void saveStepExecutions(Collection<StepExecution> stepExecutions)
           
 void updateStepExecution(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(org.springframework.yarn.integration.ip.mind.AppmasterMindScOperations appmasterScOperations)
Method Detail

saveStepExecution

public void saveStepExecution(StepExecution stepExecution)
Specified by:
saveStepExecution in interface StepExecutionDao

saveStepExecutions

public void saveStepExecutions(Collection<StepExecution> stepExecutions)
Specified by:
saveStepExecutions in interface StepExecutionDao

updateStepExecution

public void updateStepExecution(StepExecution stepExecution)
Specified by:
updateStepExecution in interface StepExecutionDao

getStepExecution

public StepExecution getStepExecution(JobExecution jobExecution,
                                      Long stepExecutionId)
Specified by:
getStepExecution in interface StepExecutionDao

addStepExecutions

public void addStepExecutions(JobExecution jobExecution)
Specified by:
addStepExecutions in interface StepExecutionDao