|
|||||||||
| PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
| SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD | ||||||||
java.lang.Objectorg.springframework.data.hadoop.mapreduce.JobTasklet
public class JobTasklet
Batch tasklet for executing one Hadoop job. Can be configured to not wait for the job to finish - by default the tasklet waits for the job submitted to finish.
| Constructor Summary | |
|---|---|
JobTasklet()
|
|
| Method Summary | |
|---|---|
void |
afterPropertiesSet()
|
RepeatStatus |
execute(StepContribution contribution,
ChunkContext chunkContext)
|
void |
setBeanFactory(BeanFactory beanFactory)
|
void |
setJob(Job job)
Sets the job to execute. |
void |
setJobName(String jobName)
Sets the job to execute by (bean) name. |
void |
setWaitForJob(boolean waitForJob)
Indicates whether the tasklet should return for the job to complete (default) after submission or not. |
| Methods inherited from class java.lang.Object |
|---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
| Constructor Detail |
|---|
public JobTasklet()
| Method Detail |
|---|
public void afterPropertiesSet()
afterPropertiesSet in interface InitializingBean
public RepeatStatus execute(StepContribution contribution,
ChunkContext chunkContext)
throws Exception
execute in interface TaskletExceptionpublic void setJob(Job job)
job - The job to execute.public void setJobName(String jobName)
jobName - The job to execute.public void setWaitForJob(boolean waitForJob)
waitForJob - whether to wait for the job to complete or not.
public void setBeanFactory(BeanFactory beanFactory)
throws BeansException
setBeanFactory in interface BeanFactoryAwareBeansException
|
|||||||||
| PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
| SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD | ||||||||