org.springframework.yarn.batch.repository
Class RemoteJobRepository

java.lang.Object
  extended by org.springframework.yarn.batch.repository.AbstractRemoteDao
      extended by org.springframework.yarn.batch.repository.RemoteJobRepository
All Implemented Interfaces:
JobRepository

public class RemoteJobRepository
extends AbstractRemoteDao
implements JobRepository


Constructor Summary
RemoteJobRepository()
           
RemoteJobRepository(org.springframework.yarn.integration.ip.mind.AppmasterMindScOperations appmasterScOperations)
           
 
Method Summary
 void add(StepExecution stepExecution)
           
 void addAll(Collection<StepExecution> stepExecutions)
           
 JobExecution createJobExecution(JobInstance jobInstance, JobParameters jobParameters, String jobConfigurationLocation)
           
 JobExecution createJobExecution(String jobName, JobParameters jobParameters)
           
 JobInstance createJobInstance(String jobName, JobParameters jobParameters)
           
 JobExecution getLastJobExecution(String jobName, JobParameters jobParameters)
           
 StepExecution getLastStepExecution(JobInstance jobInstance, String stepName)
           
 int getStepExecutionCount(JobInstance jobInstance, String stepName)
           
 boolean isJobInstanceExists(String jobName, JobParameters jobParameters)
           
 void update(JobExecution jobExecution)
           
 void update(StepExecution stepExecution)
           
 void updateExecutionContext(JobExecution jobExecution)
           
 void updateExecutionContext(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(org.springframework.yarn.integration.ip.mind.AppmasterMindScOperations appmasterScOperations)
Method Detail

isJobInstanceExists

public boolean isJobInstanceExists(String jobName,
                                   JobParameters jobParameters)
Specified by:
isJobInstanceExists in interface JobRepository

createJobExecution

public JobExecution createJobExecution(String jobName,
                                       JobParameters jobParameters)
                                throws JobExecutionAlreadyRunningException,
                                       JobRestartException,
                                       JobInstanceAlreadyCompleteException
Specified by:
createJobExecution in interface JobRepository
Throws:
JobExecutionAlreadyRunningException
JobRestartException
JobInstanceAlreadyCompleteException

update

public void update(JobExecution jobExecution)
Specified by:
update in interface JobRepository

add

public void add(StepExecution stepExecution)
Specified by:
add in interface JobRepository

addAll

public void addAll(Collection<StepExecution> stepExecutions)
Specified by:
addAll in interface JobRepository

update

public void update(StepExecution stepExecution)
Specified by:
update in interface JobRepository

updateExecutionContext

public void updateExecutionContext(StepExecution stepExecution)
Specified by:
updateExecutionContext in interface JobRepository

updateExecutionContext

public void updateExecutionContext(JobExecution jobExecution)
Specified by:
updateExecutionContext in interface JobRepository

getLastStepExecution

public StepExecution getLastStepExecution(JobInstance jobInstance,
                                          String stepName)
Specified by:
getLastStepExecution in interface JobRepository

getStepExecutionCount

public int getStepExecutionCount(JobInstance jobInstance,
                                 String stepName)
Specified by:
getStepExecutionCount in interface JobRepository

getLastJobExecution

public JobExecution getLastJobExecution(String jobName,
                                        JobParameters jobParameters)
Specified by:
getLastJobExecution in interface JobRepository

createJobInstance

public JobInstance createJobInstance(String jobName,
                                     JobParameters jobParameters)
Specified by:
createJobInstance in interface JobRepository

createJobExecution

public JobExecution createJobExecution(JobInstance jobInstance,
                                       JobParameters jobParameters,
                                       String jobConfigurationLocation)
Specified by:
createJobExecution in interface JobRepository