org.springframework.cloud.task.app.spark.yarn

Class SparkYarnTaskProperties

java.lang.Object

org.springframework.cloud.task.app.spark.yarn.SparkYarnTaskProperties

@ConfigurationProperties(value="spark")
public class SparkYarnTaskProperties
extends Object

Configuration properties to be used for YARN submission. These are in addition to the ones defined in the common one.

Author:

Thomas Risberg

Constructor Summary

Constructors

Constructor and Description
SparkYarnTaskProperties()

Method Summary

Modifier and Type	Method and Description
String[]	getAppArgs()
String	getAppClass()
String	getAppJar()
String	getAppName()
String	getAssemblyJar()
String	getExecutorMemory()
int	getNumExecutors()
String	getResourceArchives()
String	getResourceFiles()
void	setAppArgs(String[] appArgs)
void	setAppClass(String appClass)
void	setAppJar(String appJar)
void	setAppName(String appName)
void	setAssemblyJar(String assemblyJar)
void	setExecutorMemory(String executorMemory)
void	setNumExecutors(int numExecutors)
void	setResourceArchives(String resourceArchives)
void	setResourceFiles(String resourceFiles)

Methods inherited from class java.lang.Object

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

Constructor Detail

SparkYarnTaskProperties

public SparkYarnTaskProperties()

Method Detail

getAssemblyJar

@NotNull
public String getAssemblyJar()

setAssemblyJar

public void setAssemblyJar(String assemblyJar)

getNumExecutors

public int getNumExecutors()

setNumExecutors

public void setNumExecutors(int numExecutors)

getAppName

public String getAppName()

setAppName

public void setAppName(String appName)

getAppClass

@NotNull
public String getAppClass()

setAppClass

public void setAppClass(String appClass)

getAppJar

@NotNull
public String getAppJar()

setAppJar

public void setAppJar(String appJar)

getAppArgs

public String[] getAppArgs()

setAppArgs

public void setAppArgs(String[] appArgs)

getResourceFiles

public String getResourceFiles()

setResourceFiles

public void setResourceFiles(String resourceFiles)

getResourceArchives

public String getResourceArchives()

setResourceArchives

public void setResourceArchives(String resourceArchives)

getExecutorMemory

public String getExecutorMemory()

setExecutorMemory

public void setExecutorMemory(String executorMemory)