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:
- 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
| Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
RemoteStepExecutionDao
public RemoteStepExecutionDao()
RemoteStepExecutionDao
public RemoteStepExecutionDao(org.springframework.yarn.integration.ip.mind.AppmasterMindScOperations appmasterScOperations)
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