org.springframework.yarn.batch.repository
Class RemoteJobInstanceDao

java.lang.Object
  extended by org.springframework.yarn.batch.repository.AbstractRemoteDao
      extended by 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

Constructor Summary
RemoteJobInstanceDao()
           
RemoteJobInstanceDao(org.springframework.yarn.integration.ip.mind.AppmasterMindScOperations appmasterScOperations)
           
 
Method Summary
 JobInstance createJobInstance(String jobName, JobParameters jobParameters)
           
 JobInstance getJobInstance(JobExecution jobExecution)
           
 JobInstance getJobInstance(Long instanceId)
           
 JobInstance getJobInstance(String jobName, JobParameters jobParameters)
           
 List<JobInstance> getJobInstances(String jobName, int start, int count)
           
 List<String> getJobNames()
           
 
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

RemoteJobInstanceDao

public RemoteJobInstanceDao()

RemoteJobInstanceDao

public RemoteJobInstanceDao(org.springframework.yarn.integration.ip.mind.AppmasterMindScOperations appmasterScOperations)
Method Detail

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