public class ToolTasklet extends org.springframework.data.hadoop.mapreduce.ToolExecutor implements Tasklet, InitializingBean
Tools.| Constructor and Description |
|---|
ToolTasklet() |
| Modifier and Type | Method and Description |
|---|---|
void |
afterPropertiesSet() |
protected java.lang.ClassLoader |
createClassLoaderForJar(Resource arg0,
java.lang.ClassLoader arg1,
Configuration arg2) |
RepeatStatus |
execute(StepContribution contribution,
ChunkContext chunkContext) |
protected void |
postExecution(Configuration arg0) |
protected void |
preExecution(Configuration arg0) |
protected Configuration |
resolveConfiguration() |
protected java.lang.Class<T> |
resolveTargetClass(Configuration arg0) |
protected T |
resolveTargetObject(java.lang.Class<T> arg0) |
protected int |
runCode() |
void |
setSystemProcessExitCodeMapper(SystemProcessExitCodeMapper systemProcessExitCodeMapper) |
public RepeatStatus execute(StepContribution contribution, ChunkContext chunkContext) throws java.lang.Exception
public void afterPropertiesSet()
throws java.lang.Exception
afterPropertiesSet in interface InitializingBeanafterPropertiesSet in class org.springframework.data.hadoop.mapreduce.ToolExecutorjava.lang.Exceptionpublic void setSystemProcessExitCodeMapper(SystemProcessExitCodeMapper systemProcessExitCodeMapper)
systemProcessExitCodeMapper - maps system process return value to
ExitStatus returned by Tasklet.
SimpleSystemProcessExitCodeMapper is used by default.protected int runCode()
throws java.lang.Exception
java.lang.Exceptionprotected Configuration resolveConfiguration() throws java.lang.Exception
java.lang.Exceptionprotected java.lang.Class<T> resolveTargetClass(Configuration arg0) throws java.lang.Exception
java.lang.Exceptionprotected T resolveTargetObject(java.lang.Class<T> arg0)
protected java.lang.ClassLoader createClassLoaderForJar(Resource arg0, java.lang.ClassLoader arg1, Configuration arg2)
protected void preExecution(Configuration arg0)
protected void postExecution(Configuration arg0)