public class JarTasklet extends JarExecutor implements org.springframework.batch.core.step.tasklet.Tasklet
Constructor and Description |
---|
JarTasklet() |
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) |
protected java.lang.Class<T> |
loadClass(java.lang.String className,
java.lang.ClassLoader cl) |
protected org.apache.hadoop.conf.Configuration |
resolveConfiguration() |
protected java.lang.Class<T> |
resolveTargetClass(org.apache.hadoop.conf.Configuration cfg) |
protected int |
runCode() |
void |
setArchives(org.springframework.core.io.Resource... archives)
Sets the archives to be unarchive to the map reduce cluster.
|
void |
setArguments(java.lang.String... arguments)
Sets the arguments.
|
void |
setBeanClassLoader(java.lang.ClassLoader classLoader) |
void |
setCloseFs(boolean closeFs)
Indicates whether or not to close the Hadoop file-systems
resulting from the custom code execution.
|
void |
setConfiguration(org.apache.hadoop.conf.Configuration configuration)
Sets the configuration.
|
void |
setFiles(org.springframework.core.io.Resource... files)
Sets the files to be copied to the map reduce cluster.
|
void |
setJar(org.springframework.core.io.Resource jar)
Sets the target code jar.
|
void |
setLibs(org.springframework.core.io.Resource... libJars)
Sets the jar files to include in the classpath.
|
void |
setProperties(java.util.Properties properties)
Sets the properties.
|
void |
setUser(java.lang.String user)
Sets the user impersonation (optional) for running this job.
|
afterPropertiesSet, createClassLoaderForJar, invokeTargetObject, postExecution, preExecution, resolveTargetObject, setMainClass
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
execute
in interface org.springframework.batch.core.step.tasklet.Tasklet
java.lang.Exception
protected int runCode() throws java.lang.Exception
java.lang.Exception
protected org.apache.hadoop.conf.Configuration resolveConfiguration() throws java.lang.Exception
java.lang.Exception
protected java.lang.Class<T> resolveTargetClass(org.apache.hadoop.conf.Configuration cfg) throws java.lang.Exception
java.lang.Exception
protected java.lang.Class<T> loadClass(java.lang.String className, java.lang.ClassLoader cl)
public void setJar(org.springframework.core.io.Resource jar)
jar
- target jarpublic void setArguments(java.lang.String... arguments)
arguments
- The arguments to set.public void setConfiguration(org.apache.hadoop.conf.Configuration configuration)
configuration
- The configuration to set.public void setProperties(java.util.Properties properties)
properties
- The properties to set.public void setBeanClassLoader(java.lang.ClassLoader classLoader)
setBeanClassLoader
in interface org.springframework.beans.factory.BeanClassLoaderAware
public void setCloseFs(boolean closeFs)
closeFs
- the new close fspublic void setLibs(org.springframework.core.io.Resource... libJars)
mydir/*.jar
), which the
Spring container will automatically resolve.libJars
- The jar files to include in the classpath.public void setFiles(org.springframework.core.io.Resource... files)
mydir/*.txt
), which the
Spring container will automatically resolve.files
- The files to copy.public void setArchives(org.springframework.core.io.Resource... archives)
mydir/*.zip
), which the
Spring container will automatically resolve.archives
- The archives to unarchive on the compute machines.public void setUser(java.lang.String user)
user
- user/group information