public class RemoteJobExplorer extends AbstractRemoteDao implements JobExplorer
| Constructor and Description |
|---|
RemoteJobExplorer() |
RemoteJobExplorer(org.springframework.yarn.integration.ip.mind.AppmasterMindScOperations appmasterScOperations) |
| Modifier and Type | Method and Description |
|---|---|
List<JobInstance> |
findJobInstancesByJobName(String jobName,
int start,
int count) |
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) |
checkResponseMayThrow, convertException, getAppmasterScOperations, setAppmasterScOperationspublic RemoteJobExplorer()
public RemoteJobExplorer(org.springframework.yarn.integration.ip.mind.AppmasterMindScOperations appmasterScOperations)
public List<JobInstance> getJobInstances(String jobName, int start, int count)
getJobInstances in interface JobExplorerpublic JobExecution getJobExecution(Long executionId)
getJobExecution in interface JobExplorerpublic StepExecution getStepExecution(Long jobExecutionId, Long stepExecutionId)
getStepExecution in interface JobExplorerpublic JobInstance getJobInstance(Long instanceId)
getJobInstance in interface JobExplorerpublic List<JobExecution> getJobExecutions(JobInstance jobInstance)
getJobExecutions in interface JobExplorerpublic Set<JobExecution> findRunningJobExecutions(String jobName)
findRunningJobExecutions in interface JobExplorerpublic List<String> getJobNames()
getJobNames in interface JobExplorerpublic int getJobInstanceCount(String jobName) throws NoSuchJobException
getJobInstanceCount in interface JobExplorerNoSuchJobExceptionpublic List<JobInstance> findJobInstancesByJobName(String jobName, int start, int count)
findJobInstancesByJobName in interface JobExplorer