Package | Description |
---|---|
org.apache.flink.tests.util.flink |
Modifier and Type | Method and Description |
---|---|
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.setParallelism(int parallelism)
Sets the parallelism for the job.
|
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.