org.springframework.data.hadoop.batch.mapreduce

Class JobTasklet

java.lang.Object

org.springframework.data.hadoop.mapreduce.JobExecutor

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

All Implemented Interfaces:

org.springframework.batch.core.step.tasklet.Tasklet, org.springframework.beans.factory.Aware, org.springframework.beans.factory.BeanFactoryAware, org.springframework.beans.factory.DisposableBean, org.springframework.beans.factory.InitializingBean

public class JobTasklet
extends JobExecutor
implements org.springframework.batch.core.step.tasklet.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

JobExecutor.JobListener

Field Summary

Fields inherited from class org.springframework.data.hadoop.mapreduce.JobExecutor

log

Constructor Summary

Constructors

Constructor and Description
JobTasklet()

Method Summary

Methods

Modifier and Type	Method and Description
org.springframework.batch.repeat.RepeatStatus	execute(org.springframework.batch.core.StepContribution contribution, org.springframework.batch.core.scope.context.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 org.springframework.batch.repeat.RepeatStatus execute(org.springframework.batch.core.StepContribution contribution,
                                                    org.springframework.batch.core.scope.context.ChunkContext chunkContext)
                                                      throws java.lang.Exception

Specified by:

execute in interface org.springframework.batch.core.step.tasklet.Tasklet

Throws:

java.lang.Exception