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

java.lang.Object
  extended by org.springframework.data.hadoop.mapreduce.JarExecutor
      extended by org.springframework.data.hadoop.batch.mapreduce.JarTasklet
All Implemented Interfaces:
Tasklet, Aware, BeanClassLoaderAware, InitializingBean

public class JarTasklet
extends org.springframework.data.hadoop.mapreduce.JarExecutor
implements Tasklet

Batch tasklet for executing Hadoop jars.

Author:
Costin Leau

Constructor Summary
JarTasklet()
           
 
Method Summary
 RepeatStatus execute(StepContribution contribution, ChunkContext chunkContext)
           
protected  Class<T> loadClass(String arg0, ClassLoader arg1)
           
protected  Configuration resolveConfiguration()
           
protected  Class<T> resolveTargetClass(Configuration arg0)
           
protected  int runCode()
           
 
Methods inherited from class org.springframework.data.hadoop.mapreduce.JarExecutor
afterPropertiesSet, createClassLoaderForJar, invokeTargetObject, postExecution, preExecution, resolveTargetObject, setMainClass
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Constructor Detail

JarTasklet

public JarTasklet()
Method Detail

execute

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

runCode

protected int runCode()
               throws Exception
Throws:
Exception

resolveConfiguration

protected Configuration resolveConfiguration()
                                      throws Exception
Throws:
Exception

resolveTargetClass

protected Class<T> resolveTargetClass(Configuration arg0)
                               throws Exception
Throws:
Exception

loadClass

protected Class<T> loadClass(String arg0,
                             ClassLoader arg1)