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

Constructors

Constructor and Description
RemoteJobExplorer()
RemoteJobExplorer(AppmasterMindScOperations appmasterScOperations)

Method Summary

Methods

Modifier and Type	Method and Description
java.util.List<org.springframework.batch.core.JobInstance>	findJobInstancesByJobName(java.lang.String jobName, int start, int count)
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

findJobInstancesByJobName

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

Specified by:

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