org.springframework.yarn.batch.repository
Class RemoteJobInstanceDao

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

All Implemented Interfaces:

org.springframework.batch.core.repository.dao.JobInstanceDao

public class RemoteJobInstanceDao
extends AbstractRemoteDao
implements org.springframework.batch.core.repository.dao.JobInstanceDao

Proxy implementation of JobInstanceDao. Simply uses RpcMessage instances to talk to remote service which should handle the actual JobInstanceDao logic.

Author:

Janne Valkealahti

Constructor Summary

RemoteJobInstanceDao()

RemoteJobInstanceDao(AppmasterMindScOperations appmasterScOperations)

Method Summary

org.springframework.batch.core.JobInstance	createJobInstance(java.lang.String jobName, org.springframework.batch.core.JobParameters jobParameters)
org.springframework.batch.core.JobInstance	getJobInstance(org.springframework.batch.core.JobExecution jobExecution)
org.springframework.batch.core.JobInstance	getJobInstance(java.lang.Long instanceId)
org.springframework.batch.core.JobInstance	getJobInstance(java.lang.String jobName, org.springframework.batch.core.JobParameters jobParameters)
java.util.List<org.springframework.batch.core.JobInstance>	getJobInstances(java.lang.String jobName, int start, int count)
java.util.List<java.lang.String>	getJobNames()

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

RemoteJobInstanceDao

public RemoteJobInstanceDao()

RemoteJobInstanceDao

public RemoteJobInstanceDao(AppmasterMindScOperations appmasterScOperations)

Method Detail

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.dao.JobInstanceDao

getJobInstance

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

Specified by:

getJobInstance in interface org.springframework.batch.core.repository.dao.JobInstanceDao

getJobInstance

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

Specified by:

getJobInstance in interface org.springframework.batch.core.repository.dao.JobInstanceDao

getJobInstance

public org.springframework.batch.core.JobInstance getJobInstance(org.springframework.batch.core.JobExecution jobExecution)

Specified by:

getJobInstance in interface org.springframework.batch.core.repository.dao.JobInstanceDao

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.repository.dao.JobInstanceDao

getJobNames

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

Specified by:

getJobNames in interface org.springframework.batch.core.repository.dao.JobInstanceDao