|
Spring for Apache Hadoop | ||||||||
| PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
| SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD | ||||||||
java.lang.Objectorg.springframework.yarn.batch.repository.JobRepositoryRpcFactory
public class JobRepositoryRpcFactory
Helper class providing factory methods for building requests used in remote job repository functionality.
| Constructor Summary | |
|---|---|
JobRepositoryRpcFactory()
|
|
| Method Summary | |
|---|---|
static AddWithStepExecutionReq |
buildAddWithStepExecutionReq(org.springframework.batch.core.StepExecution stepExecution)
|
static CreateJobExecutionReq |
buildCreateJobExecutionReq(java.lang.String jobName,
org.springframework.batch.core.JobParameters jobParameters)
|
static CreateJobExecutionWithJobInstanceReq |
buildCreateJobExecutionWithJobInstanceReq(org.springframework.batch.core.JobInstance jobInstance,
org.springframework.batch.core.JobParameters jobParameters,
java.lang.String jobConfigurationLocation)
|
static CreateJobInstanceReq |
buildCreateJobInstanceReq(java.lang.String jobName,
org.springframework.batch.core.JobParameters jobParameters)
|
static FindRunningJobExecutionsReq |
buildFindRunningJobExecutionsReq(java.lang.String jobName)
|
static GetJobExecutionReq |
buildGetJobExecutionReq(java.lang.Long executionId)
|
static GetJobExecutionsReq |
buildGetJobExecutionsReq(org.springframework.batch.core.JobInstance jobInstance)
|
static GetJobInstanceCountReq |
buildGetJobInstanceCountReq(java.lang.String jobName)
|
static GetJobInstanceReq |
buildGetJobInstanceReq(java.lang.Long instanceId)
|
static GetJobInstancesReq |
buildGetJobInstancesReq(java.lang.String jobName,
int start,
int count)
Builds request for getting a job instance by its name and paging info. |
static GetJobNamesReq |
buildGetJobNamesReq()
|
static GetLastJobExecutionReq |
buildGetLastJobExecutionReq(java.lang.String jobName,
org.springframework.batch.core.JobParameters jobParameters)
|
static GetLastStepExecutionReq |
buildGetLastStepExecutionReq(org.springframework.batch.core.JobInstance jobInstance,
java.lang.String stepName)
|
static GetStepExecutionCountReq |
buildGetStepExecutionCountReq(org.springframework.batch.core.JobInstance jobInstance,
java.lang.String stepName)
|
static GetStepExecutionReq |
buildGetStepExecutionReq(java.lang.Long jobExecutionId,
java.lang.Long stepExecutionId)
|
static IsJobInstanceExistsReq |
buildIsJobInstanceExistsReq(java.lang.String jobName,
org.springframework.batch.core.JobParameters jobParameters)
|
static UpdateWithJobExecutionReq |
buildSaveJobExecutionReq(org.springframework.batch.core.JobExecution jobExecution)
|
static UpdateExecutionContextReq |
buildUpdateExecutionContextReq(org.springframework.batch.core.JobExecution jobExecution)
Builds request for updating execution context from a job execution. |
static UpdateExecutionContextReq |
buildUpdateExecutionContextReq(org.springframework.batch.core.StepExecution stepExecution)
Builds request for updating execution context from a step execution. |
static UpdateWithStepExecutionReq |
buildUpdateWithStepExecutionReq(org.springframework.batch.core.StepExecution stepExecution)
|
static ExecutionContextType |
convertExecutionContext(org.springframework.batch.item.ExecutionContext executionContext)
Converts a ExecutionContext to ExecutionContextType. |
static org.springframework.batch.item.ExecutionContext |
convertExecutionContextType(ExecutionContextType executionContextType)
Converts a ExecutionContextType to ExecutionContext. |
static JobExecutionType |
convertJobExecutionType(org.springframework.batch.core.JobExecution jobExecution)
Creates JobExecutionType from JobExecution. |
static JobExecutionType |
convertJobExecutionType(org.springframework.batch.core.JobExecution jobExecution,
org.springframework.batch.core.StepExecution stepExecution)
Creates JobExecutionType from JobExecution. |
static org.springframework.batch.core.JobExecution |
convertJobExecutionType(JobExecutionType type)
Converts a JobExecutionType to JobExecution. |
static JobInstanceType |
convertJobInstanceType(org.springframework.batch.core.JobInstance jobInstance)
Converts a JobInstance to JobInstanceType. |
static org.springframework.batch.core.JobInstance |
convertJobInstanceType(JobInstanceType type)
Converts a JobInstanceType to JobInstance. |
static JobParametersType |
convertJobParameters(org.springframework.batch.core.JobParameters jobParameters)
Converts a JobParameters to JobParametersType. |
static org.springframework.batch.core.JobParameters |
convertJobParametersType(JobParametersType type)
Converts a JobParametersType to JobParameters. |
static StepExecutionType |
convertStepExecutionType(org.springframework.batch.core.StepExecution stepExecution)
Creates StepExecutionType from StepExecution. |
static StepExecutionType |
convertStepExecutionType(org.springframework.batch.core.StepExecution stepExecution,
org.springframework.batch.core.JobExecution jobExecution)
Creates StepExecutionType from StepExecution. |
static org.springframework.batch.core.StepExecution |
convertStepExecutionType(StepExecutionType type)
Converts a StepExecutionType to StepExecution. |
| Methods inherited from class java.lang.Object |
|---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
| Constructor Detail |
|---|
public JobRepositoryRpcFactory()
| Method Detail |
|---|
public static StepExecutionType convertStepExecutionType(org.springframework.batch.core.StepExecution stepExecution)
StepExecutionType from StepExecution.
stepExecution - the step execution
convertStepExecutionType(StepExecution, JobExecution)
public static StepExecutionType convertStepExecutionType(org.springframework.batch.core.StepExecution stepExecution,
org.springframework.batch.core.JobExecution jobExecution)
StepExecutionType from StepExecution. Second
argument JobExecution is only used as a back reference to
prevent never ending loop for serialization logic due to references
between StepExecution and JobExecution.
stepExecution - the step executionjobExecution - the job execution
public static ExecutionContextType convertExecutionContext(org.springframework.batch.item.ExecutionContext executionContext)
ExecutionContext to ExecutionContextType.
executionContext - the execution context
public static org.springframework.batch.item.ExecutionContext convertExecutionContextType(ExecutionContextType executionContextType)
ExecutionContextType to ExecutionContext.
executionContextType - the execution context type
public static org.springframework.batch.core.StepExecution convertStepExecutionType(StepExecutionType type)
StepExecutionType to StepExecution.
type - the step execution type
public static JobExecutionType convertJobExecutionType(org.springframework.batch.core.JobExecution jobExecution)
JobExecutionType from JobExecution.
jobExecution - the job execution
convertJobExecutionType(JobExecution, StepExecution)
public static JobExecutionType convertJobExecutionType(org.springframework.batch.core.JobExecution jobExecution,
org.springframework.batch.core.StepExecution stepExecution)
JobExecutionType from JobExecution. Second
argument StepExecution is only used as a back reference to
prevent never ending loop for serialization logic due to references
between StepExecution and JobExecution.
jobExecution - the job executionstepExecution - the step execution
public static org.springframework.batch.core.JobExecution convertJobExecutionType(JobExecutionType type)
JobExecutionType to JobExecution.
type - the job execution type
public static JobInstanceType convertJobInstanceType(org.springframework.batch.core.JobInstance jobInstance)
JobInstance to JobInstanceType.
jobInstance - the job instance
public static org.springframework.batch.core.JobInstance convertJobInstanceType(JobInstanceType type)
JobInstanceType to JobInstance.
type - the job instance type
public static JobParametersType convertJobParameters(org.springframework.batch.core.JobParameters jobParameters)
JobParameters to JobParametersType.
jobParameters - the job parameters
public static org.springframework.batch.core.JobParameters convertJobParametersType(JobParametersType type)
JobParametersType to JobParameters.
type - the job parameters type
public static IsJobInstanceExistsReq buildIsJobInstanceExistsReq(java.lang.String jobName,
org.springframework.batch.core.JobParameters jobParameters)
public static CreateJobExecutionReq buildCreateJobExecutionReq(java.lang.String jobName,
org.springframework.batch.core.JobParameters jobParameters)
public static CreateJobInstanceReq buildCreateJobInstanceReq(java.lang.String jobName,
org.springframework.batch.core.JobParameters jobParameters)
public static CreateJobExecutionWithJobInstanceReq buildCreateJobExecutionWithJobInstanceReq(org.springframework.batch.core.JobInstance jobInstance,
org.springframework.batch.core.JobParameters jobParameters,
java.lang.String jobConfigurationLocation)
public static UpdateWithJobExecutionReq buildSaveJobExecutionReq(org.springframework.batch.core.JobExecution jobExecution)
public static AddWithStepExecutionReq buildAddWithStepExecutionReq(org.springframework.batch.core.StepExecution stepExecution)
public static GetStepExecutionCountReq buildGetStepExecutionCountReq(org.springframework.batch.core.JobInstance jobInstance,
java.lang.String stepName)
public static GetJobInstanceCountReq buildGetJobInstanceCountReq(java.lang.String jobName)
public static GetLastStepExecutionReq buildGetLastStepExecutionReq(org.springframework.batch.core.JobInstance jobInstance,
java.lang.String stepName)
public static UpdateWithStepExecutionReq buildUpdateWithStepExecutionReq(org.springframework.batch.core.StepExecution stepExecution)
public static GetLastJobExecutionReq buildGetLastJobExecutionReq(java.lang.String jobName,
org.springframework.batch.core.JobParameters jobParameters)
public static GetJobInstancesReq buildGetJobInstancesReq(java.lang.String jobName,
int start,
int count)
jobName - the job namestart - index where to startcount - max number of entries to request
GetJobInstancesReq requestpublic static GetJobInstanceReq buildGetJobInstanceReq(java.lang.Long instanceId)
public static GetJobExecutionReq buildGetJobExecutionReq(java.lang.Long executionId)
public static GetStepExecutionReq buildGetStepExecutionReq(java.lang.Long jobExecutionId,
java.lang.Long stepExecutionId)
public static GetJobExecutionsReq buildGetJobExecutionsReq(org.springframework.batch.core.JobInstance jobInstance)
public static FindRunningJobExecutionsReq buildFindRunningJobExecutionsReq(java.lang.String jobName)
public static GetJobNamesReq buildGetJobNamesReq()
public static UpdateExecutionContextReq buildUpdateExecutionContextReq(org.springframework.batch.core.StepExecution stepExecution)
stepExecution - the step execution
UpdateExecutionContextReq requestpublic static UpdateExecutionContextReq buildUpdateExecutionContextReq(org.springframework.batch.core.JobExecution jobExecution)
jobExecution - the job execution
UpdateExecutionContextReq request
|
Spring for Apache Hadoop | ||||||||
| PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
| SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD | ||||||||