org.springframework.yarn.batch.repository
Class RemoteJobExplorer

java.lang.Object
  extended by org.springframework.yarn.batch.repository.AbstractRemoteDao
      extended by org.springframework.yarn.batch.repository.RemoteJobExplorer
All Implemented Interfaces:
JobExplorer

public class RemoteJobExplorer
extends AbstractRemoteDao
implements JobExplorer


Constructor Summary
RemoteJobExplorer()
           
RemoteJobExplorer(org.springframework.yarn.integration.ip.mind.AppmasterMindScOperations appmasterScOperations)
           
 
Method Summary
 Set<JobExecution> findRunningJobExecutions(String jobName)
           
 JobExecution getJobExecution(Long executionId)
           
 List<JobExecution> getJobExecutions(JobInstance jobInstance)
           
 JobInstance getJobInstance(Long instanceId)
           
 int getJobInstanceCount(String jobName)
           
 List<JobInstance> getJobInstances(String jobName, int start, int count)
           
 List<String> getJobNames()
           
 StepExecution getStepExecution(Long jobExecutionId, Long stepExecutionId)
           
 
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

RemoteJobExplorer

public RemoteJobExplorer()

RemoteJobExplorer

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

getJobInstances

public List<JobInstance> getJobInstances(String jobName,
                                         int start,
                                         int count)
Specified by:
getJobInstances in interface JobExplorer

getJobExecution

public JobExecution getJobExecution(Long executionId)
Specified by:
getJobExecution in interface JobExplorer

getStepExecution

public StepExecution getStepExecution(Long jobExecutionId,
                                      Long stepExecutionId)
Specified by:
getStepExecution in interface JobExplorer

getJobInstance

public JobInstance getJobInstance(Long instanceId)
Specified by:
getJobInstance in interface JobExplorer

getJobExecutions

public List<JobExecution> getJobExecutions(JobInstance jobInstance)
Specified by:
getJobExecutions in interface JobExplorer

findRunningJobExecutions

public Set<JobExecution> findRunningJobExecutions(String jobName)
Specified by:
findRunningJobExecutions in interface JobExplorer

getJobNames

public List<String> getJobNames()
Specified by:
getJobNames in interface JobExplorer

getJobInstanceCount

public int getJobInstanceCount(String jobName)
                        throws NoSuchJobException
Specified by:
getJobInstanceCount in interface JobExplorer
Throws:
NoSuchJobException