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 ClassLoader |
createClassLoaderForJar(Resource arg0,
ClassLoader arg1,
Configuration arg2) |
RepeatStatus |
execute(StepContribution contribution,
ChunkContext chunkContext) |
protected void |
postExecution(Configuration arg0) |
protected void |
preExecution(Configuration arg0) |
protected Configuration |
resolveConfiguration() |
protected Class<T> |
resolveTargetClass(Configuration arg0) |
protected T |
resolveTargetObject(Class<T> arg0) |
protected int |
runCode() |
void |
setSystemProcessExitCodeMapper(SystemProcessExitCodeMapper systemProcessExitCodeMapper) |
public RepeatStatus execute(StepContribution contribution, ChunkContext chunkContext) throws Exception
public void afterPropertiesSet()
throws Exception
afterPropertiesSet in interface InitializingBeanafterPropertiesSet in class org.springframework.data.hadoop.mapreduce.ToolExecutorExceptionpublic void setSystemProcessExitCodeMapper(SystemProcessExitCodeMapper systemProcessExitCodeMapper)
systemProcessExitCodeMapper - maps system process return value to
ExitStatus returned by Tasklet.
SimpleSystemProcessExitCodeMapper is used by default.protected Configuration resolveConfiguration() throws Exception
Exceptionprotected Class<T> resolveTargetClass(Configuration arg0) throws Exception
Exceptionprotected T resolveTargetObject(Class<T> arg0)
protected ClassLoader createClassLoaderForJar(Resource arg0, ClassLoader arg1, Configuration arg2)
protected void preExecution(Configuration arg0)
protected void postExecution(Configuration arg0)