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:
- org.springframework.batch.core.repository.dao.ExecutionContextDao
public class RemoteExecutionContextDao
- extends AbstractRemoteDao
- implements org.springframework.batch.core.repository.dao.ExecutionContextDao
Proxy implementation of ExecutionContextDao
. Passes dao
methods to a remote repository via service calls using
RpcMessage
messages.
- Author:
- Janne Valkealahti
Method Summary |
org.springframework.batch.item.ExecutionContext |
getExecutionContext(org.springframework.batch.core.JobExecution jobExecution)
|
org.springframework.batch.item.ExecutionContext |
getExecutionContext(org.springframework.batch.core.StepExecution stepExecution)
|
void |
saveExecutionContext(org.springframework.batch.core.JobExecution jobExecution)
|
void |
saveExecutionContext(org.springframework.batch.core.StepExecution stepExecution)
|
void |
updateExecutionContext(org.springframework.batch.core.JobExecution jobExecution)
|
void |
updateExecutionContext(org.springframework.batch.core.StepExecution stepExecution)
|
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
RemoteExecutionContextDao
public RemoteExecutionContextDao()
RemoteExecutionContextDao
public RemoteExecutionContextDao(AppmasterMindScOperations appmasterScOperations)
getExecutionContext
public org.springframework.batch.item.ExecutionContext getExecutionContext(org.springframework.batch.core.JobExecution jobExecution)
- Specified by:
getExecutionContext
in interface org.springframework.batch.core.repository.dao.ExecutionContextDao
getExecutionContext
public org.springframework.batch.item.ExecutionContext getExecutionContext(org.springframework.batch.core.StepExecution stepExecution)
- Specified by:
getExecutionContext
in interface org.springframework.batch.core.repository.dao.ExecutionContextDao
saveExecutionContext
public void saveExecutionContext(org.springframework.batch.core.JobExecution jobExecution)
- Specified by:
saveExecutionContext
in interface org.springframework.batch.core.repository.dao.ExecutionContextDao
saveExecutionContext
public void saveExecutionContext(org.springframework.batch.core.StepExecution stepExecution)
- Specified by:
saveExecutionContext
in interface org.springframework.batch.core.repository.dao.ExecutionContextDao
updateExecutionContext
public void updateExecutionContext(org.springframework.batch.core.JobExecution jobExecution)
- Specified by:
updateExecutionContext
in interface org.springframework.batch.core.repository.dao.ExecutionContextDao
updateExecutionContext
public void updateExecutionContext(org.springframework.batch.core.StepExecution stepExecution)
- Specified by:
updateExecutionContext
in interface org.springframework.batch.core.repository.dao.ExecutionContextDao