JobSubmission.JobSubmissionBuilder |
JobSubmission.JobSubmissionBuilder.addArgument(String argument) |
Adds a program argument.
|
JobSubmission.JobSubmissionBuilder |
JobSubmission.JobSubmissionBuilder.addArgument(String key,
String value) |
Convenience method for providing key-value program arguments.
|
JobSubmission.JobSubmissionBuilder |
JobSubmission.JobSubmissionBuilder.setDetached(boolean detached) |
Sets whether the job should be submitted in a detached manner.
|
JobSubmission.JobSubmissionBuilder |
JobSubmission.JobSubmissionBuilder.setMainClass(String mainClass) |
Sets the main class for the job.
|
JobSubmission.JobSubmissionBuilder |
JobSubmission.JobSubmissionBuilder.setParallelism(int parallelism) |
Sets the parallelism for the job.
|