public class SparkYarnTasklet extends Object implements InitializingBean, Tasklet, StepExecutionListener
| Constructor and Description |
|---|
SparkYarnTasklet() |
| Modifier and Type | Method and Description |
|---|---|
void |
afterPropertiesSet() |
ExitStatus |
afterStep(StepExecution stepExecution) |
void |
beforeStep(StepExecution stepExecution) |
RepeatStatus |
execute(StepContribution contribution,
ChunkContext chunkContext) |
void |
setAppClass(String appClass) |
void |
setAppJar(String appJar) |
void |
setAppName(String appName) |
void |
setArguments(String[] arguments) |
void |
setExecutorMemory(String executorMemory) |
void |
setHadoopConfiguration(Configuration configuration) |
void |
setNumExecutors(int numExecutors) |
void |
setResourceArchives(String resourceArchives) |
void |
setResourceFiles(String resourceFiles) |
void |
setSparkAssemblyJar(String sparkAssemblyJar) |
public RepeatStatus execute(StepContribution contribution, ChunkContext chunkContext) throws Exception
public void beforeStep(StepExecution stepExecution)
beforeStep in interface StepExecutionListenerpublic ExitStatus afterStep(StepExecution stepExecution)
afterStep in interface StepExecutionListenerpublic void afterPropertiesSet()
throws Exception
afterPropertiesSet in interface InitializingBeanExceptionpublic void setSparkAssemblyJar(String sparkAssemblyJar)
public void setHadoopConfiguration(Configuration configuration)
public void setAppName(String appName)
public void setAppClass(String appClass)
public void setAppJar(String appJar)
public void setResourceFiles(String resourceFiles)
public void setResourceArchives(String resourceArchives)
public void setExecutorMemory(String executorMemory)
public void setNumExecutors(int numExecutors)
public void setArguments(String[] arguments)