org.springframework.xd.spark.tasklet

Class SparkTasklet

java.lang.Object

org.springframework.xd.spark.tasklet.SparkTasklet

All Implemented Interfaces:

org.springframework.batch.core.step.tasklet.Tasklet, org.springframework.batch.core.StepExecutionListener, org.springframework.batch.core.StepListener, org.springframework.beans.factory.Aware, org.springframework.context.EnvironmentAware

public class SparkTasklet
extends java.lang.Object
implements org.springframework.batch.core.step.tasklet.Tasklet, org.springframework.context.EnvironmentAware, org.springframework.batch.core.StepExecutionListener

Tasklet for running Spark application.

Author:

Thomas Risberg, Ilayaperumal Gopinathan

Constructor Summary

Constructors

Constructor and Description
SparkTasklet()

Method Summary

Methods

Modifier and Type	Method and Description
org.springframework.batch.core.ExitStatus	afterStep(org.springframework.batch.core.StepExecution stepExecution)
void	beforeStep(org.springframework.batch.core.StepExecution stepExecution)
org.springframework.batch.repeat.RepeatStatus	execute(org.springframework.batch.core.StepContribution contribution, org.springframework.batch.core.scope.context.ChunkContext chunkContext)
java.lang.String	getAppJar()
java.lang.String	getConf()
java.lang.String	getFiles()
java.lang.String	getMainClass()
java.lang.String	getMaster()
java.lang.String	getName()
java.lang.String	getProgramArgs()
void	setAppJar(java.lang.String appJar)
void	setConf(java.lang.String conf)
void	setEnvironment(org.springframework.core.env.Environment environment)
void	setFiles(java.lang.String files)
void	setMainClass(java.lang.String mainClass)
void	setMaster(java.lang.String master)
void	setName(java.lang.String name)
void	setProgramArgs(java.lang.String programArgs)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

SparkTasklet

public SparkTasklet()

Method Detail

getMaster

public java.lang.String getMaster()

setMaster

public void setMaster(java.lang.String master)

getMainClass

public java.lang.String getMainClass()

setMainClass

public void setMainClass(java.lang.String mainClass)

getAppJar

public java.lang.String getAppJar()

setAppJar

public void setAppJar(java.lang.String appJar)

getProgramArgs

public java.lang.String getProgramArgs()

setProgramArgs

public void setProgramArgs(java.lang.String programArgs)

getName

public java.lang.String getName()

setName

public void setName(java.lang.String name)

getConf

public java.lang.String getConf()

setConf

public void setConf(java.lang.String conf)

getFiles

public java.lang.String getFiles()

setFiles

public void setFiles(java.lang.String files)

setEnvironment

public void setEnvironment(org.springframework.core.env.Environment environment)

Specified by:

setEnvironment in interface org.springframework.context.EnvironmentAware

execute

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

Specified by:

execute in interface org.springframework.batch.core.step.tasklet.Tasklet

Throws:

java.lang.Exception

afterStep

public org.springframework.batch.core.ExitStatus afterStep(org.springframework.batch.core.StepExecution stepExecution)

Specified by:

afterStep in interface org.springframework.batch.core.StepExecutionListener

beforeStep

public void beforeStep(org.springframework.batch.core.StepExecution stepExecution)

Specified by:

beforeStep in interface org.springframework.batch.core.StepExecutionListener