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