org.springframework.xd.test.fixtures

Class SparkAppJob

java.lang.Object

org.springframework.xd.test.fixtures.AbstractModuleFixture<SparkAppJob>

org.springframework.xd.test.fixtures.SparkAppJob

public class SparkAppJob
extends AbstractModuleFixture<SparkAppJob>

A test fixture that represents the Spark App Job

Author:

Glenn Renfro

Field Summary

Fields

Modifier and Type	Field and Description
static java.lang.String	DEFAULT_APP_JAR
static java.lang.String	DEFAULT_APP_SOURCE_JAR
static java.lang.String	DEFAULT_MAIN_CLASS
static java.lang.String	DEFAULT_MASTER
static java.lang.String	DEFAULT_NAME

Fields inherited from class org.springframework.xd.test.fixtures.AbstractModuleFixture

label

Constructor Summary

Constructors

Constructor and Description
SparkAppJob(java.lang.String sparkAppName, java.lang.String sparkAppJar, java.lang.String sparkAppMainClass, java.lang.String sparkMaster) Construct a new SparkAppJob fixture using the provided spark app's name, jar, main class and master.

Method Summary

Methods

Modifier and Type	Method and Description
java.net.URI	getJarURI(java.lang.String jarLocation) Construct the URI location of the jar
java.lang.String	getSparkAppJar()
java.lang.String	getSparkAppJarSource()
java.lang.String	getSparkAppMainClass()
java.lang.String	getSparkAppName()
java.lang.String	getSparkMaster()
SparkAppJob	sparkAppJar(java.lang.String sparkAppJar) Sets the location of the spark app jar
SparkAppJob	sparkAppJarSource(java.lang.String sparkAppJarSource) Sets the location of a source jar that can be copied to the target location where XD can access the jar
SparkAppJob	sparkAppMainClass(java.lang.String sparkAppMainClass) Sets the package and class of spark app
SparkAppJob	sparkAppName(java.lang.String sparkAppName) Sets the spark App Name for the fixture
SparkAppJob	sparkMaster(java.lang.String sparkMaster) Sets The url of the spark master(spark://url:7077 or localhost[x]
java.lang.String	toDSL() Renders the default DSL for this fixture.
static SparkAppJob	withDefaults() Creates an instance of the SparkAppJob fixture using defaults.

Methods inherited from class org.springframework.xd.test.fixtures.AbstractModuleFixture

label, toString

Methods inherited from class java.lang.Object

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

Field Detail

DEFAULT_NAME

public static final java.lang.String DEFAULT_NAME

See Also:

Constant Field Values

DEFAULT_APP_JAR

public static final java.lang.String DEFAULT_APP_JAR

See Also:

Constant Field Values

DEFAULT_MASTER

public static final java.lang.String DEFAULT_MASTER

See Also:

Constant Field Values

DEFAULT_MAIN_CLASS

public static final java.lang.String DEFAULT_MAIN_CLASS

See Also:

Constant Field Values

DEFAULT_APP_SOURCE_JAR

public static final java.lang.String DEFAULT_APP_SOURCE_JAR

See Also:

Constant Field Values

Constructor Detail

SparkAppJob

public SparkAppJob(java.lang.String sparkAppName,
           java.lang.String sparkAppJar,
           java.lang.String sparkAppMainClass,
           java.lang.String sparkMaster)

Construct a new SparkAppJob fixture using the provided spark app's name, jar, main class and master.

Parameters:

sparkAppName - the name of the spark app

sparkAppJar - the jar that contains the spark app

sparkAppMainClass - the package and class name

sparkMaster - either local[x] or the spark://URL

Method Detail

withDefaults

public static SparkAppJob withDefaults()

Creates an instance of the SparkAppJob fixture using defaults.

Returns:

an instance of the SparkAppJob fixture.

toDSL

public java.lang.String toDSL()

Renders the default DSL for this fixture.

Specified by:

toDSL in class AbstractModuleFixture<SparkAppJob>

getJarURI

public java.net.URI getJarURI(java.lang.String jarLocation)

Construct the URI location of the jar

Parameters:

jarLocation - String location of the jar

Returns:

the URI for the location of the JAR

sparkAppName

public SparkAppJob sparkAppName(java.lang.String sparkAppName)

Sets the spark App Name for the fixture

Parameters:

sparkAppName - the name for the spark app

Returns:

current instance the job.

sparkAppJar

public SparkAppJob sparkAppJar(java.lang.String sparkAppJar)

Sets the location of the spark app jar

Parameters:

sparkAppJar - the location of the spark app jar

Returns:

current instance the job.

sparkAppMainClass

public SparkAppJob sparkAppMainClass(java.lang.String sparkAppMainClass)

Sets the package and class of spark app

Parameters:

sparkAppMainClass - the package and class of the spark app

Returns:

current instance the job.

sparkMaster

public SparkAppJob sparkMaster(java.lang.String sparkMaster)

Sets The url of the spark master(spark://url:7077 or localhost[x]

Parameters:

sparkMaster - the location of the spark master or localhost

Returns:

current instance the job.

sparkAppJarSource

public SparkAppJob sparkAppJarSource(java.lang.String sparkAppJarSource)

Sets the location of a source jar that can be copied to the target location where XD can access the jar

Parameters:

sparkAppJarSource - the location of the spark app jar.

Returns:

current instance the job.

getSparkAppName

public java.lang.String getSparkAppName()

getSparkAppJar

public java.lang.String getSparkAppJar()

getSparkAppMainClass

public java.lang.String getSparkAppMainClass()

getSparkMaster

public java.lang.String getSparkMaster()

getSparkAppJarSource

public java.lang.String getSparkAppJarSource()