org.springframework.yarn.batch.repository
Class RemoteJobExplorer

java.lang.Object
  org.springframework.yarn.batch.repository.AbstractRemoteDao
      org.springframework.yarn.batch.repository.RemoteJobExplorer

All Implemented Interfaces:

org.springframework.batch.core.explore.JobExplorer

public class RemoteJobExplorer
extends AbstractRemoteDao
implements org.springframework.batch.core.explore.JobExplorer

Constructor Summary

RemoteJobExplorer()

RemoteJobExplorer(AppmasterMindScOperations appmasterScOperations)

Method Summary

java.util.Set<org.springframework.batch.core.JobExecution>	findRunningJobExecutions(java.lang.String jobName)
org.springframework.batch.core.JobExecution	getJobExecution(java.lang.Long executionId)
java.util.List<org.springframework.batch.core.JobExecution>	getJobExecutions(org.springframework.batch.core.JobInstance jobInstance)
org.springframework.batch.core.JobInstance	getJobInstance(java.lang.Long instanceId)
int	getJobInstanceCount(java.lang.String jobName)
java.util.List<org.springframework.batch.core.JobInstance>	getJobInstances(java.lang.String jobName, int start, int count)
java.util.List<java.lang.String>	getJobNames()
org.springframework.batch.core.StepExecution	getStepExecution(java.lang.Long jobExecutionId, java.lang.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(AppmasterMindScOperations appmasterScOperations)

Method Detail

getJobInstances

public java.util.List<org.springframework.batch.core.JobInstance> getJobInstances(java.lang.String jobName,
                                                                                  int start,
                                                                                  int count)

Specified by:

getJobInstances in interface org.springframework.batch.core.explore.JobExplorer

getJobExecution

public org.springframework.batch.core.JobExecution getJobExecution(java.lang.Long executionId)

Specified by:

getJobExecution in interface org.springframework.batch.core.explore.JobExplorer

getStepExecution

public org.springframework.batch.core.StepExecution getStepExecution(java.lang.Long jobExecutionId,
                                                                     java.lang.Long stepExecutionId)

Specified by:

getStepExecution in interface org.springframework.batch.core.explore.JobExplorer

getJobInstance

public org.springframework.batch.core.JobInstance getJobInstance(java.lang.Long instanceId)

Specified by:

getJobInstance in interface org.springframework.batch.core.explore.JobExplorer

getJobExecutions

public java.util.List<org.springframework.batch.core.JobExecution> getJobExecutions(org.springframework.batch.core.JobInstance jobInstance)

Specified by:

getJobExecutions in interface org.springframework.batch.core.explore.JobExplorer

findRunningJobExecutions

public java.util.Set<org.springframework.batch.core.JobExecution> findRunningJobExecutions(java.lang.String jobName)

Specified by:

findRunningJobExecutions in interface org.springframework.batch.core.explore.JobExplorer

getJobNames

public java.util.List<java.lang.String> getJobNames()

Specified by:

getJobNames in interface org.springframework.batch.core.explore.JobExplorer

getJobInstanceCount

public int getJobInstanceCount(java.lang.String jobName)
                        throws org.springframework.batch.core.launch.NoSuchJobException

Specified by:

getJobInstanceCount in interface org.springframework.batch.core.explore.JobExplorer

Throws:

org.springframework.batch.core.launch.NoSuchJobException