public class SparkSubmitCommandBuilder extends Object
| Modifier and Type | Method and Description |
|---|---|
String |
build() |
static SparkSubmitCommandBuilder |
newInstance(String sparkMasterUrl,
String jarFilePath) |
SparkSubmitCommandBuilder |
withDefaultParallelism(int parallelism) |
SparkSubmitCommandBuilder |
withDriverMemory(String driverMemory) |
SparkSubmitCommandBuilder |
withEnv(String env) |
SparkSubmitCommandBuilder |
withExecutorCores(int executorCores) |
SparkSubmitCommandBuilder |
withExecutorMemory(String executorMemory) |
SparkSubmitCommandBuilder |
withInfo(Object algorithmProperties) |
SparkSubmitCommandBuilder |
withMainClass(String mainClass) |
SparkSubmitCommandBuilder |
withMaxCores(int maxCores) |
SparkSubmitCommandBuilder |
withNumExecutors(int numExecutors) |
SparkSubmitCommandBuilder |
withSparkRootPath(String sparkRootPath) |
SparkSubmitCommandBuilder |
withSpringProfile(String activeProfile) |
public static final String JVMGC
public SparkSubmitCommandBuilder withSparkRootPath(String sparkRootPath)
public static SparkSubmitCommandBuilder newInstance(String sparkMasterUrl, String jarFilePath)
public SparkSubmitCommandBuilder withNumExecutors(int numExecutors)
public SparkSubmitCommandBuilder withDefaultParallelism(int parallelism)
public SparkSubmitCommandBuilder withMaxCores(int maxCores)
public SparkSubmitCommandBuilder withMainClass(String mainClass)
public SparkSubmitCommandBuilder withExecutorCores(int executorCores)
public SparkSubmitCommandBuilder withEnv(String env)
public SparkSubmitCommandBuilder withExecutorMemory(String executorMemory)
public SparkSubmitCommandBuilder withDriverMemory(String driverMemory)
public SparkSubmitCommandBuilder withInfo(Object algorithmProperties)
public String build()
public SparkSubmitCommandBuilder withSpringProfile(String activeProfile)
Copyright © 2017. All rights reserved.