|
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 AddStepExecutionsReq |
buildAddStepExecutionsReq(org.springframework.batch.core.JobExecution jobExecution)
Builds request for adding step executionf from a job execution. |
static CreateJobInstanceReq |
buildCreateJobInstanceReq(java.lang.String jobName,
org.springframework.batch.core.JobParameters jobParameters)
Builds request for creating a job instance. |
static FindJobExecutionsReq |
buildFindJobExecutionsReq(org.springframework.batch.core.JobInstance jobInstance)
Builds request for finding a job execution by a job instance. |
static FindRunningJobExecutionsReq |
buildFindRunningJobExecutionsReq(java.lang.String jobName)
Builds request for finding a job executions by a job name. |
static GetExecutionContextReq |
buildGetExecutionContextReq(org.springframework.batch.core.JobExecution jobExecution)
Builds request for getting execution context from a job execution. |
static GetExecutionContextReq |
buildGetExecutionContextReq(org.springframework.batch.core.StepExecution stepExecution)
Builds request for getting execution context from a step execution. |
static GetJobExecutionReq |
buildGetJobExecutionReq(java.lang.Long executionId)
Builds request for getting a job execution by its execution id. |
static GetJobInstanceByIdReq |
buildGetJobInstanceByIdReq(java.lang.Long id)
Builds request for getting a job instance by id. |
static GetJobInstanceReq |
buildGetJobInstanceReq(java.lang.String jobName,
org.springframework.batch.core.JobParameters jobParameters)
Builds request for getting a job instance. |
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()
Builds request for getting a job names. |
static GetLastJobExecutionReq |
buildGetLastJobExecutionReq(org.springframework.batch.core.JobInstance jobInstance)
Builds request for getting a last execution by a job instance. |
static GetStepExecutionReq |
buildGetStepExecutionReq(org.springframework.batch.core.JobExecution jobExecution,
java.lang.Long stepExecutionId)
Builds request for getting a step execution job execution and step execution id. |
static SaveExecutionContextReq |
buildSaveExecutionContextReq(org.springframework.batch.core.JobExecution jobExecution)
Builds request for saving execution context from a job execution. |
static SaveExecutionContextReq |
buildSaveExecutionContextReq(org.springframework.batch.core.StepExecution stepExecution)
Builds request for saving execution context from a step execution. |
static SaveJobExecutionReq |
buildSaveJobExecutionReq(org.springframework.batch.core.JobExecution jobExecution)
Builds request for saving a job execution. |
static SaveStepExecutionReq |
buildSaveStepExecutionReq(org.springframework.batch.core.StepExecution stepExecution)
Builds request for saving a step execution. |
static SynchronizeStatusReq |
buildSynchronizeStatusReq(org.springframework.batch.core.JobExecution jobExecution)
Builds request for synchronizing a job execution status. |
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 UpdateJobExecutionReq |
buildUpdateJobExecutionReq(org.springframework.batch.core.JobExecution jobExecution)
Builds request for updating a job execution. |
static UpdateStepExecutionReq |
buildUpdateStepExecutionReq(org.springframework.batch.core.StepExecution stepExecution)
Builds request for updating a step execution. |
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 SaveStepExecutionReq buildSaveStepExecutionReq(org.springframework.batch.core.StepExecution stepExecution)
stepExecution - the step execution
SaveStepExecutionReq requestpublic static AddStepExecutionsReq buildAddStepExecutionsReq(org.springframework.batch.core.JobExecution jobExecution)
jobExecution - the job execution
AddStepExecutionsReq requestpublic static UpdateStepExecutionReq buildUpdateStepExecutionReq(org.springframework.batch.core.StepExecution stepExecution)
stepExecution - the step execution
UpdateStepExecutionReq request
public static GetStepExecutionReq buildGetStepExecutionReq(org.springframework.batch.core.JobExecution jobExecution,
java.lang.Long stepExecutionId)
jobExecution - the job executionstepExecutionId - the step execution id
GetStepExecutionReq requestpublic static UpdateJobExecutionReq buildUpdateJobExecutionReq(org.springframework.batch.core.JobExecution jobExecution)
jobExecution - the job execution
UpdateJobExecutionReq requestpublic static SynchronizeStatusReq buildSynchronizeStatusReq(org.springframework.batch.core.JobExecution jobExecution)
jobExecution - the job execution
SynchronizeStatusReq requestpublic static SaveJobExecutionReq buildSaveJobExecutionReq(org.springframework.batch.core.JobExecution jobExecution)
jobExecution - the job execution
SaveJobExecutionReq requestpublic static SaveExecutionContextReq buildSaveExecutionContextReq(org.springframework.batch.core.StepExecution stepExecution)
stepExecution - the step execution
SaveExecutionContextReq requestpublic static SaveExecutionContextReq buildSaveExecutionContextReq(org.springframework.batch.core.JobExecution jobExecution)
jobExecution - the job execution
SaveExecutionContextReq requestpublic 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 requestpublic static GetExecutionContextReq buildGetExecutionContextReq(org.springframework.batch.core.StepExecution stepExecution)
stepExecution - the step execution
GetExecutionContextReq requestpublic static GetExecutionContextReq buildGetExecutionContextReq(org.springframework.batch.core.JobExecution jobExecution)
jobExecution - the step execution
GetExecutionContextReq requestpublic 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 CreateJobInstanceReq buildCreateJobInstanceReq(java.lang.String jobName,
org.springframework.batch.core.JobParameters jobParameters)
jobName - the job namejobParameters - the job parameters
CreateJobInstanceReq request
public static GetJobInstanceReq buildGetJobInstanceReq(java.lang.String jobName,
org.springframework.batch.core.JobParameters jobParameters)
jobName - the job namejobParameters - the job parameters
GetJobInstanceReq requestpublic static GetJobInstanceByIdReq buildGetJobInstanceByIdReq(java.lang.Long id)
id - the job instance id
GetJobInstanceByIdReq request
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 GetLastJobExecutionReq buildGetLastJobExecutionReq(org.springframework.batch.core.JobInstance jobInstance)
jobInstance - the job instance
GetLastJobExecutionReq requestpublic static FindJobExecutionsReq buildFindJobExecutionsReq(org.springframework.batch.core.JobInstance jobInstance)
jobInstance - the job instance
FindJobExecutionsReq requestpublic static FindRunningJobExecutionsReq buildFindRunningJobExecutionsReq(java.lang.String jobName)
jobName - the job name
FindRunningJobExecutionsReq requestpublic static GetJobExecutionReq buildGetJobExecutionReq(java.lang.Long executionId)
executionId - the execution id
GetJobExecutionReq requestpublic static GetJobNamesReq buildGetJobNamesReq()
GetJobNamesReq request
|
Spring for Apache Hadoop | ||||||||
| PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
| SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD | ||||||||