<T> FlinkContainersSettings.Builder |
FlinkContainersSettings.Builder.basedOn(org.apache.flink.configuration.Configuration config) |
Merges the provided config with the default config, potentially overwriting the
defaults in case of collisions.
|
FlinkContainersSettings.Builder |
FlinkContainersSettings.Builder.baseImage(String baseImage) |
Sets the baseImage and returns a reference to this Builder enabling method
chaining.
|
static FlinkContainersSettings.Builder |
FlinkContainersSettings.builder() |
A new builder for FlinkContainersConfig.
|
FlinkContainersSettings.Builder |
FlinkContainersSettings.Builder.checkpointPath(String checkpointPath) |
Sets the checkpointPath and returns a reference to this Builder enabling method
chaining.
|
FlinkContainersSettings.Builder |
FlinkContainersSettings.Builder.enableZookeeperHA() |
Enables Zookeeper HA.
|
FlinkContainersSettings.Builder |
FlinkContainersSettings.Builder.flinkDistLocation(String flinkDistLocation) |
Sets the flinkDistLocation and returns a reference to this Builder enabling
method chaining.
|
FlinkContainersSettings.Builder |
FlinkContainersSettings.Builder.flinkHome(String flinkHome) |
Sets the path of the Flink distribution inside the container.
|
<T> FlinkContainersSettings.Builder |
FlinkContainersSettings.Builder.fullConfiguration(org.apache.flink.configuration.Configuration config) |
Sets the flinkConfiguration value to config and returns a reference to
this Builder enabling method chaining.
|
FlinkContainersSettings.Builder |
FlinkContainersSettings.Builder.haStoragePath(String haStoragePath) |
Sets the haStoragePath and returns a reference to this Builder enabling method
chaining.
|
FlinkContainersSettings.Builder |
FlinkContainersSettings.Builder.jarPaths(String... jarPaths) |
Sets the jarPaths and returns a reference to this Builder enabling method
chaining.
|
FlinkContainersSettings.Builder |
FlinkContainersSettings.Builder.jarPaths(Collection<String> jarPaths) |
Sets the jarPaths and returns a reference to this Builder enabling method
chaining.
|
FlinkContainersSettings.Builder |
FlinkContainersSettings.Builder.jobManagerHostname(String jobManagerHostname) |
Sets the job manager hostname and returns a reference to this Builder enabling method
chaining.
|
FlinkContainersSettings.Builder |
FlinkContainersSettings.Builder.numSlotsPerTaskManager(int numSlotsPerTaskManager) |
Sets the numSlotsPerTaskManager and returns a reference to this Builder enabling
method chaining.
|
FlinkContainersSettings.Builder |
FlinkContainersSettings.Builder.numTaskManagers(int numTaskManagers) |
Sets the numTaskManagers and returns a reference to this Builder enabling method
chaining.
|
<T> FlinkContainersSettings.Builder |
FlinkContainersSettings.Builder.setConfigOption(org.apache.flink.configuration.ConfigOption<T> option,
T value) |
Sets a single Flink configuration parameter (the options for config.yaml) and returns a
reference to this Builder enabling method chaining.
|
FlinkContainersSettings.Builder |
FlinkContainersSettings.Builder.setLogProperty(String key,
String value) |
Sets a single Flink logging configuration property in the log4j format and returns a
reference to this Builder enabling method chaining.
|
FlinkContainersSettings.Builder |
FlinkContainersSettings.Builder.taskManagerHostnamePrefix(String taskManagerHostnamePrefix) |
Sets the taskManagerHostnamePrefix and returns a reference to this Builder
enabling method chaining.
|
FlinkContainersSettings.Builder |
FlinkContainersSettings.Builder.zookeeperHostname(String zookeeperHostname) |
Sets the zookeeperHostname and returns a reference to this Builder enabling
method chaining.
|