org.springframework.cloud.task.app.spark.cluster

Class SparkClusterTaskProperties

java.lang.Object

org.springframework.cloud.task.app.spark.cluster.SparkClusterTaskProperties

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

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

Author:

Thomas Risberg

Constructor Summary

Constructors

Constructor and Description
SparkClusterTaskProperties()

Method Summary

Modifier and Type	Method and Description
String[]	getAppArgs()
String	getAppClass()
String	getAppJar()
String	getAppName()
long	getAppStatusPollInterval()
String	getExecutorMemory()
String	getMaster()
String	getResourceArchives()
String	getResourceFiles()
String	getRestUrl()
void	setAppArgs(String[] appArgs)
void	setAppClass(String appClass)
void	setAppJar(String appJar)
void	setAppName(String appName)
void	setAppStatusPollInterval(long appStatusPollInterval)
void	setExecutorMemory(String executorMemory)
void	setMaster(String master)
void	setResourceArchives(String resourceArchives)
void	setResourceFiles(String resourceFiles)
void	setRestUrl(String restUrl)

Methods inherited from class java.lang.Object

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

Constructor Detail

SparkClusterTaskProperties

public SparkClusterTaskProperties()

Method Detail

getMaster

public String getMaster()

setMaster

public void setMaster(String master)

getRestUrl

public String getRestUrl()

setRestUrl

public void setRestUrl(String restUrl)

getAppStatusPollInterval

public long getAppStatusPollInterval()

setAppStatusPollInterval

public void setAppStatusPollInterval(long appStatusPollInterval)

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)