public abstract class SparkJobSetting
extends java.lang.Object
spark 任务参数设置
限定符和类型 | 字段和说明 |
---|---|
java.lang.String |
appName
应用名称
|
java.lang.String[] |
args
参数
|
ContextSetting |
contextSetting
spark
|
static java.lang.String |
DEFAULT_MASTER_ADRESS |
java.lang.String |
mainClass
函数入口
|
PublishServiceResult |
serviceInfo
任务处理结果发布的服务信息
|
java.io.File |
sparkLogFile
spark任务进程的输出文件位置
|
构造器和说明 |
---|
SparkJobSetting() |
SparkJobSetting(SparkJobSetting setting) |
限定符和类型 | 方法和说明 |
---|---|
SparkJobSetting |
appName(java.lang.String appName) |
SparkJobSetting |
args(java.lang.String[] args) |
SparkJobSetting |
contextSetting(ContextSetting contextSetting) |
abstract SparkJobSetting |
copy() |
SparkJobSetting |
mainClass(java.lang.String mainClass) |
SparkJobSetting |
sparkLogFile(java.io.File sparkLogFile) |
public static final java.lang.String DEFAULT_MASTER_ADRESS
public ContextSetting contextSetting
public java.lang.String appName
public java.lang.String mainClass
public java.lang.String[] args
public PublishServiceResult serviceInfo
public java.io.File sparkLogFile
public SparkJobSetting()
public SparkJobSetting(SparkJobSetting setting)
public SparkJobSetting appName(java.lang.String appName)
public SparkJobSetting contextSetting(ContextSetting contextSetting)
public SparkJobSetting mainClass(java.lang.String mainClass)
public SparkJobSetting sparkLogFile(java.io.File sparkLogFile)
public SparkJobSetting args(java.lang.String[] args)
public abstract SparkJobSetting copy()