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,
org.apache.hadoop.conf.Configuration arg2) |
RepeatStatus |
execute(StepContribution contribution,
ChunkContext chunkContext) |
protected void |
postExecution(org.apache.hadoop.conf.Configuration arg0) |
protected void |
preExecution(org.apache.hadoop.conf.Configuration arg0) |
protected org.apache.hadoop.conf.Configuration |
resolveConfiguration() |
protected Class<T> |
resolveTargetClass(org.apache.hadoop.conf.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 org.apache.hadoop.conf.Configuration resolveConfiguration()
throws Exception
Exceptionprotected Class<T> resolveTargetClass(org.apache.hadoop.conf.Configuration arg0) throws Exception
Exceptionprotected T resolveTargetObject(Class<T> arg0)
protected ClassLoader createClassLoaderForJar(Resource arg0, ClassLoader arg1, org.apache.hadoop.conf.Configuration arg2)
protected void preExecution(org.apache.hadoop.conf.Configuration arg0)
protected void postExecution(org.apache.hadoop.conf.Configuration arg0)