|
|||||||||
| 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()
|
|
| 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(StepExecution stepExecution)
StepExecutionType from StepExecution.
stepExecution - the step execution
convertStepExecutionType(StepExecution, JobExecution)
public static StepExecutionType convertStepExecutionType(StepExecution stepExecution,
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(ExecutionContext executionContext)
ExecutionContext to ExecutionContextType.
executionContext - the execution context
public static ExecutionContext convertExecutionContextType(ExecutionContextType executionContextType)
ExecutionContextType to ExecutionContext.
executionContextType - the execution context type
public static StepExecution convertStepExecutionType(StepExecutionType type)
StepExecutionType to StepExecution.
type - the step execution type
public static JobExecutionType convertJobExecutionType(JobExecution jobExecution)
JobExecutionType from JobExecution.
jobExecution - the job execution
convertJobExecutionType(JobExecution, StepExecution)
public static JobExecutionType convertJobExecutionType(JobExecution jobExecution,
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 JobExecution convertJobExecutionType(JobExecutionType type)
JobExecutionType to JobExecution.
type - the job execution type
public static JobInstanceType convertJobInstanceType(JobInstance jobInstance)
JobInstance to JobInstanceType.
jobInstance - the job instance
public static JobInstance convertJobInstanceType(JobInstanceType type)
JobInstanceType to JobInstance.
type - the job instance type
public static JobParametersType convertJobParameters(JobParameters jobParameters)
JobParameters to JobParametersType.
jobParameters - the job parameters
public static JobParameters convertJobParametersType(JobParametersType type)
JobParametersType to JobParameters.
type - the job parameters type
public static IsJobInstanceExistsReq buildIsJobInstanceExistsReq(String jobName,
JobParameters jobParameters)
public static CreateJobExecutionReq buildCreateJobExecutionReq(String jobName,
JobParameters jobParameters)
public static CreateJobInstanceReq buildCreateJobInstanceReq(String jobName,
JobParameters jobParameters)
public static CreateJobExecutionWithJobInstanceReq buildCreateJobExecutionWithJobInstanceReq(JobInstance jobInstance,
JobParameters jobParameters,
String jobConfigurationLocation)
public static UpdateWithJobExecutionReq buildSaveJobExecutionReq(JobExecution jobExecution)
public static AddWithStepExecutionReq buildAddWithStepExecutionReq(StepExecution stepExecution)
public static GetStepExecutionCountReq buildGetStepExecutionCountReq(JobInstance jobInstance,
String stepName)
public static GetJobInstanceCountReq buildGetJobInstanceCountReq(String jobName)
public static GetLastStepExecutionReq buildGetLastStepExecutionReq(JobInstance jobInstance,
String stepName)
public static UpdateWithStepExecutionReq buildUpdateWithStepExecutionReq(StepExecution stepExecution)
public static GetLastJobExecutionReq buildGetLastJobExecutionReq(String jobName,
JobParameters jobParameters)
public static GetJobInstancesReq buildGetJobInstancesReq(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(Long instanceId)
public static GetJobExecutionReq buildGetJobExecutionReq(Long executionId)
public static GetStepExecutionReq buildGetStepExecutionReq(Long jobExecutionId,
Long stepExecutionId)
public static GetJobExecutionsReq buildGetJobExecutionsReq(JobInstance jobInstance)
public static FindRunningJobExecutionsReq buildFindRunningJobExecutionsReq(String jobName)
public static GetJobNamesReq buildGetJobNamesReq()
public static UpdateExecutionContextReq buildUpdateExecutionContextReq(StepExecution stepExecution)
stepExecution - the step execution
UpdateExecutionContextReq requestpublic static UpdateExecutionContextReq buildUpdateExecutionContextReq(JobExecution jobExecution)
jobExecution - the job execution
UpdateExecutionContextReq request
|
|||||||||
| PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
| SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD | ||||||||