org.springframework.data.hadoop.batch.mapreduce
Class JobTasklet

java.lang.Object
  extended by org.springframework.data.hadoop.mapreduce.JobExecutor
      extended by org.springframework.data.hadoop.batch.mapreduce.JobTasklet
All Implemented Interfaces:
Tasklet, Aware, BeanFactoryAware, DisposableBean, InitializingBean

public class JobTasklet
extends org.springframework.data.hadoop.mapreduce.JobExecutor
implements Tasklet

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.

Author:
Costin Leau, Thomas Risberg

Nested Class Summary
 
Nested classes/interfaces inherited from class org.springframework.data.hadoop.mapreduce.JobExecutor
org.springframework.data.hadoop.mapreduce.JobExecutor.JobListener
 
Field Summary
 
Fields inherited from class org.springframework.data.hadoop.mapreduce.JobExecutor
log
 
Constructor Summary
JobTasklet()
           
 
Method Summary
 RepeatStatus execute(StepContribution contribution, ChunkContext chunkContext)
           
 
Methods inherited from class org.springframework.data.hadoop.mapreduce.JobExecutor
afterPropertiesSet, destroy, findJobs, isKillJobsAtShutdown, isVerbose, isWaitForCompletion, setBeanFactory, setExecutor, setJob, setJobNames, setJobs, setKillJobAtShutdown, setVerbose, setWaitForCompletion, startJobs, startJobs, stopJobs, stopJobs
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Constructor Detail

JobTasklet

public JobTasklet()
Method Detail

execute

public RepeatStatus execute(StepContribution contribution,
                            ChunkContext chunkContext)
                     throws Exception
Specified by:
execute in interface Tasklet
Throws:
Exception