org.springframework.yarn.batch.repository
Class RemoteExecutionContextDao
java.lang.Object
org.springframework.yarn.batch.repository.AbstractRemoteDao
org.springframework.yarn.batch.repository.RemoteExecutionContextDao
- All Implemented Interfaces:
- ExecutionContextDao
public class RemoteExecutionContextDao
- extends AbstractRemoteDao
- implements ExecutionContextDao
Proxy implementation of ExecutionContextDao. 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 |
RemoteExecutionContextDao
public RemoteExecutionContextDao()
RemoteExecutionContextDao
public RemoteExecutionContextDao(org.springframework.yarn.integration.ip.mind.AppmasterMindScOperations appmasterScOperations)
getExecutionContext
public ExecutionContext getExecutionContext(JobExecution jobExecution)
- Specified by:
getExecutionContext in interface ExecutionContextDao
getExecutionContext
public ExecutionContext getExecutionContext(StepExecution stepExecution)
- Specified by:
getExecutionContext in interface ExecutionContextDao
saveExecutionContext
public void saveExecutionContext(JobExecution jobExecution)
- Specified by:
saveExecutionContext in interface ExecutionContextDao
saveExecutionContext
public void saveExecutionContext(StepExecution stepExecution)
- Specified by:
saveExecutionContext in interface ExecutionContextDao
saveExecutionContexts
public void saveExecutionContexts(Collection<StepExecution> stepExecutions)
- Specified by:
saveExecutionContexts in interface ExecutionContextDao
updateExecutionContext
public void updateExecutionContext(JobExecution jobExecution)
- Specified by:
updateExecutionContext in interface ExecutionContextDao
updateExecutionContext
public void updateExecutionContext(StepExecution stepExecution)
- Specified by:
updateExecutionContext in interface ExecutionContextDao