org.springframework.yarn.batch.repository
Class RemoteJobRepository

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

All Implemented Interfaces:

org.springframework.batch.core.repository.JobRepository

public class RemoteJobRepository
extends AbstractRemoteDao
implements org.springframework.batch.core.repository.JobRepository

Constructor Summary

RemoteJobRepository()

RemoteJobRepository(AppmasterMindScOperations appmasterScOperations)

Method Summary

void	add(org.springframework.batch.core.StepExecution stepExecution)
void	addAll(java.util.Collection<org.springframework.batch.core.StepExecution> stepExecutions)
org.springframework.batch.core.JobExecution	createJobExecution(org.springframework.batch.core.JobInstance jobInstance, org.springframework.batch.core.JobParameters jobParameters, java.lang.String jobConfigurationLocation)
org.springframework.batch.core.JobExecution	createJobExecution(java.lang.String jobName, org.springframework.batch.core.JobParameters jobParameters)
org.springframework.batch.core.JobInstance	createJobInstance(java.lang.String jobName, org.springframework.batch.core.JobParameters jobParameters)
org.springframework.batch.core.JobExecution	getLastJobExecution(java.lang.String jobName, org.springframework.batch.core.JobParameters jobParameters)
org.springframework.batch.core.StepExecution	getLastStepExecution(org.springframework.batch.core.JobInstance jobInstance, java.lang.String stepName)
int	getStepExecutionCount(org.springframework.batch.core.JobInstance jobInstance, java.lang.String stepName)
boolean	isJobInstanceExists(java.lang.String jobName, org.springframework.batch.core.JobParameters jobParameters)
void	update(org.springframework.batch.core.JobExecution jobExecution)
void	update(org.springframework.batch.core.StepExecution stepExecution)
void	updateExecutionContext(org.springframework.batch.core.JobExecution jobExecution)
void	updateExecutionContext(org.springframework.batch.core.StepExecution stepExecution)

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

RemoteJobRepository

public RemoteJobRepository()

RemoteJobRepository

public RemoteJobRepository(AppmasterMindScOperations appmasterScOperations)

Method Detail

isJobInstanceExists

public boolean isJobInstanceExists(java.lang.String jobName,
                                   org.springframework.batch.core.JobParameters jobParameters)

Specified by:

isJobInstanceExists in interface org.springframework.batch.core.repository.JobRepository

createJobExecution

public org.springframework.batch.core.JobExecution createJobExecution(java.lang.String jobName,
                                                                      org.springframework.batch.core.JobParameters jobParameters)
                                                               throws org.springframework.batch.core.repository.JobExecutionAlreadyRunningException,
                                                                      org.springframework.batch.core.repository.JobRestartException,
                                                                      org.springframework.batch.core.repository.JobInstanceAlreadyCompleteException

Specified by:

createJobExecution in interface org.springframework.batch.core.repository.JobRepository

Throws:

org.springframework.batch.core.repository.JobExecutionAlreadyRunningException

org.springframework.batch.core.repository.JobRestartException

org.springframework.batch.core.repository.JobInstanceAlreadyCompleteException

update

public void update(org.springframework.batch.core.JobExecution jobExecution)

Specified by:

update in interface org.springframework.batch.core.repository.JobRepository

add

public void add(org.springframework.batch.core.StepExecution stepExecution)

Specified by:

add in interface org.springframework.batch.core.repository.JobRepository

addAll

public void addAll(java.util.Collection<org.springframework.batch.core.StepExecution> stepExecutions)

Specified by:

addAll in interface org.springframework.batch.core.repository.JobRepository

update

public void update(org.springframework.batch.core.StepExecution stepExecution)

Specified by:

update in interface org.springframework.batch.core.repository.JobRepository

updateExecutionContext

public void updateExecutionContext(org.springframework.batch.core.StepExecution stepExecution)

Specified by:

updateExecutionContext in interface org.springframework.batch.core.repository.JobRepository

updateExecutionContext

public void updateExecutionContext(org.springframework.batch.core.JobExecution jobExecution)

Specified by:

updateExecutionContext in interface org.springframework.batch.core.repository.JobRepository

getLastStepExecution

public org.springframework.batch.core.StepExecution getLastStepExecution(org.springframework.batch.core.JobInstance jobInstance,
                                                                         java.lang.String stepName)

Specified by:

getLastStepExecution in interface org.springframework.batch.core.repository.JobRepository

getStepExecutionCount

public int getStepExecutionCount(org.springframework.batch.core.JobInstance jobInstance,
                                 java.lang.String stepName)

Specified by:

getStepExecutionCount in interface org.springframework.batch.core.repository.JobRepository

getLastJobExecution

public org.springframework.batch.core.JobExecution getLastJobExecution(java.lang.String jobName,
                                                                       org.springframework.batch.core.JobParameters jobParameters)

Specified by:

getLastJobExecution in interface org.springframework.batch.core.repository.JobRepository

createJobInstance

public org.springframework.batch.core.JobInstance createJobInstance(java.lang.String jobName,
                                                                    org.springframework.batch.core.JobParameters jobParameters)

Specified by:

createJobInstance in interface org.springframework.batch.core.repository.JobRepository

createJobExecution

public org.springframework.batch.core.JobExecution createJobExecution(org.springframework.batch.core.JobInstance jobInstance,
                                                                      org.springframework.batch.core.JobParameters jobParameters,
                                                                      java.lang.String jobConfigurationLocation)

Specified by:

createJobExecution in interface org.springframework.batch.core.repository.JobRepository