public final class SparkJobProperties extends Object
Constructor and Description |
---|
SparkJobProperties() |
Modifier and Type | Method and Description |
---|---|
Map<String,Object> |
getAdditionalProperties()
Get the additionalProperties property: The properties of the Spark job.
|
List<String> |
getArchives()
Get the archives property: Archives to be used in this job.
|
List<String> |
getArgs()
Get the args property: Command line arguments for the application.
|
String |
getClassName()
Get the className property: Main class for Java/Scala application.
|
Object |
getConf()
Get the conf property: Spark configuration properties.
|
int |
getDriverCores()
Get the driverCores property: Number of cores to use for the driver.
|
String |
getDriverMemory()
Get the driverMemory property: Amount of memory to use for the driver process.
|
int |
getExecutorCores()
Get the executorCores property: Number of cores to use for each executor.
|
String |
getExecutorMemory()
Get the executorMemory property: Amount of memory to use per executor process.
|
String |
getFile()
Get the file property: File containing the application to execute.
|
List<String> |
getFiles()
Get the files property: files to be used in this job.
|
List<String> |
getJars()
Get the jars property: Jars to be used in this job.
|
String |
getName()
Get the name property: The name of the job.
|
int |
getNumExecutors()
Get the numExecutors property: Number of executors to launch for this job.
|
SparkJobProperties |
setAdditionalProperties(Map<String,Object> additionalProperties)
Set the additionalProperties property: The properties of the Spark job.
|
SparkJobProperties |
setArchives(List<String> archives)
Set the archives property: Archives to be used in this job.
|
SparkJobProperties |
setArgs(List<String> args)
Set the args property: Command line arguments for the application.
|
SparkJobProperties |
setClassName(String className)
Set the className property: Main class for Java/Scala application.
|
SparkJobProperties |
setConf(Object conf)
Set the conf property: Spark configuration properties.
|
SparkJobProperties |
setDriverCores(int driverCores)
Set the driverCores property: Number of cores to use for the driver.
|
SparkJobProperties |
setDriverMemory(String driverMemory)
Set the driverMemory property: Amount of memory to use for the driver process.
|
SparkJobProperties |
setExecutorCores(int executorCores)
Set the executorCores property: Number of cores to use for each executor.
|
SparkJobProperties |
setExecutorMemory(String executorMemory)
Set the executorMemory property: Amount of memory to use per executor process.
|
SparkJobProperties |
setFile(String file)
Set the file property: File containing the application to execute.
|
SparkJobProperties |
setFiles(List<String> files)
Set the files property: files to be used in this job.
|
SparkJobProperties |
setJars(List<String> jars)
Set the jars property: Jars to be used in this job.
|
SparkJobProperties |
setName(String name)
Set the name property: The name of the job.
|
SparkJobProperties |
setNumExecutors(int numExecutors)
Set the numExecutors property: Number of executors to launch for this job.
|
public String getName()
public SparkJobProperties setName(String name)
name
- the name value to set.public String getFile()
public SparkJobProperties setFile(String file)
file
- the file value to set.public String getClassName()
public SparkJobProperties setClassName(String className)
className
- the className value to set.public Object getConf()
public SparkJobProperties setConf(Object conf)
conf
- the conf value to set.public List<String> getArgs()
public SparkJobProperties setArgs(List<String> args)
args
- the args value to set.public List<String> getJars()
public SparkJobProperties setJars(List<String> jars)
jars
- the jars value to set.public List<String> getFiles()
public SparkJobProperties setFiles(List<String> files)
files
- the files value to set.public List<String> getArchives()
public SparkJobProperties setArchives(List<String> archives)
archives
- the archives value to set.public String getDriverMemory()
public SparkJobProperties setDriverMemory(String driverMemory)
driverMemory
- the driverMemory value to set.public int getDriverCores()
public SparkJobProperties setDriverCores(int driverCores)
driverCores
- the driverCores value to set.public String getExecutorMemory()
public SparkJobProperties setExecutorMemory(String executorMemory)
executorMemory
- the executorMemory value to set.public int getExecutorCores()
public SparkJobProperties setExecutorCores(int executorCores)
executorCores
- the executorCores value to set.public int getNumExecutors()
public SparkJobProperties setNumExecutors(int numExecutors)
numExecutors
- the numExecutors value to set.public Map<String,Object> getAdditionalProperties()
public SparkJobProperties setAdditionalProperties(Map<String,Object> additionalProperties)
additionalProperties
- the additionalProperties value to set.Copyright © 2021 Microsoft Corporation. All rights reserved.