|
Spring for Apache Hadoop | ||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Object org.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
requestpublic 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
requestpublic 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
requestpublic 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 |