org.springframework.yarn.batch.repository
Class RemoteJobInstanceDao
java.lang.Object
org.springframework.yarn.batch.repository.AbstractRemoteDao
org.springframework.yarn.batch.repository.RemoteJobInstanceDao
- All Implemented Interfaces:
- JobInstanceDao
public class RemoteJobInstanceDao
- extends AbstractRemoteDao
- implements JobInstanceDao
Proxy implementation of JobInstanceDao. Simply uses
RpcMessage instances to talk to remote service which
should handle the actual JobInstanceDao logic.
- Author:
- Janne Valkealahti
| Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
RemoteJobInstanceDao
public RemoteJobInstanceDao()
RemoteJobInstanceDao
public RemoteJobInstanceDao(org.springframework.yarn.integration.ip.mind.AppmasterMindScOperations appmasterScOperations)
createJobInstance
public JobInstance createJobInstance(String jobName,
JobParameters jobParameters)
- Specified by:
createJobInstance in interface JobInstanceDao
getJobInstance
public JobInstance getJobInstance(String jobName,
JobParameters jobParameters)
- Specified by:
getJobInstance in interface JobInstanceDao
getJobInstance
public JobInstance getJobInstance(Long instanceId)
- Specified by:
getJobInstance in interface JobInstanceDao
getJobInstance
public JobInstance getJobInstance(JobExecution jobExecution)
- Specified by:
getJobInstance in interface JobInstanceDao
getJobInstances
public List<JobInstance> getJobInstances(String jobName,
int start,
int count)
- Specified by:
getJobInstances in interface JobInstanceDao
getJobNames
public List<String> getJobNames()
- Specified by:
getJobNames in interface JobInstanceDao