public static final class FlinkContainersSettings.Builder extends Object
FlinkContainersConfig
builder static inner class.Modifier and Type | Method and Description |
---|---|
<T> FlinkContainersSettings.Builder |
basedOn(Configuration config)
Merges the provided
config with the default config, potentially overwriting the
defaults in case of collisions. |
FlinkContainersSettings.Builder |
baseImage(String baseImage)
Sets the
baseImage and returns a reference to this Builder enabling method
chaining. |
FlinkContainersSettings |
build()
Returns a
FlinkContainersConfig built from the parameters previously set. |
FlinkContainersSettings.Builder |
checkpointPath(String checkpointPath)
Sets the
checkpointPath and returns a reference to this Builder enabling method
chaining. |
FlinkContainersSettings.Builder |
enableZookeeperHA()
Enables Zookeeper HA.
|
FlinkContainersSettings.Builder |
flinkDistLocation(String flinkDistLocation)
Sets the
flinkDistLocation and returns a reference to this Builder enabling
method chaining. |
FlinkContainersSettings.Builder |
flinkHome(String flinkHome)
Sets the path of the Flink distribution inside the container.
|
<T> FlinkContainersSettings.Builder |
fullConfiguration(Configuration config)
Sets the
flinkConfiguration value to config and returns a reference to
this Builder enabling method chaining. |
FlinkContainersSettings.Builder |
haStoragePath(String haStoragePath)
Sets the
haStoragePath and returns a reference to this Builder enabling method
chaining. |
FlinkContainersSettings.Builder |
jarPaths(Collection<String> jarPaths)
Sets the
jarPaths and returns a reference to this Builder enabling method
chaining. |
FlinkContainersSettings.Builder |
jarPaths(String... jarPaths)
Sets the
jarPaths and returns a reference to this Builder enabling method
chaining. |
FlinkContainersSettings.Builder |
jobManagerHostname(String jobManagerHostname)
Sets the job manager hostname and returns a reference to this Builder enabling method
chaining.
|
FlinkContainersSettings.Builder |
numSlotsPerTaskManager(int numSlotsPerTaskManager)
Sets the
numSlotsPerTaskManager and returns a reference to this Builder enabling
method chaining. |
FlinkContainersSettings.Builder |
numTaskManagers(int numTaskManagers)
Sets the
numTaskManagers and returns a reference to this Builder enabling method
chaining. |
<T> FlinkContainersSettings.Builder |
setConfigOption(ConfigOption<T> option,
T value)
Sets a single Flink configuration parameter (the options for flink-conf.yaml) and returns
a reference to this Builder enabling method chaining.
|
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 |
taskManagerHostnamePrefix(String taskManagerHostnamePrefix)
Sets the
taskManagerHostnamePrefix and returns a reference to this Builder
enabling method chaining. |
FlinkContainersSettings.Builder |
zookeeperHostname(String zookeeperHostname)
Sets the
zookeeperHostname and returns a reference to this Builder enabling
method chaining. |
public FlinkContainersSettings.Builder baseImage(String baseImage)
baseImage
and returns a reference to this Builder enabling method
chaining.baseImage
- The baseImage
to set.public FlinkContainersSettings.Builder flinkDistLocation(String flinkDistLocation)
flinkDistLocation
and returns a reference to this Builder enabling
method chaining.flinkDistLocation
- The flinkDistLocation
to set.public FlinkContainersSettings.Builder flinkHome(String flinkHome)
flinkHome
- The flinkHome
to set.public FlinkContainersSettings.Builder checkpointPath(String checkpointPath)
checkpointPath
and returns a reference to this Builder enabling method
chaining.checkpointPath
- The checkpoint path to set.public FlinkContainersSettings.Builder haStoragePath(String haStoragePath)
haStoragePath
and returns a reference to this Builder enabling method
chaining.haStoragePath
- The path for storing HA data.public FlinkContainersSettings.Builder zookeeperHostname(String zookeeperHostname)
zookeeperHostname
and returns a reference to this Builder enabling
method chaining.zookeeperHostname
- The Zookeeper hostname.public FlinkContainersSettings.Builder enableZookeeperHA()
basedOn()
method instead.public FlinkContainersSettings.Builder numTaskManagers(int numTaskManagers)
numTaskManagers
and returns a reference to this Builder enabling method
chaining.numTaskManagers
- The numTaskManagers
to set.public FlinkContainersSettings.Builder numSlotsPerTaskManager(int numSlotsPerTaskManager)
numSlotsPerTaskManager
and returns a reference to this Builder enabling
method chaining. It also adds this property into the flinkConfiguration
field.numSlotsPerTaskManager
- The numSlotsPerTaskManager
to set.public FlinkContainersSettings.Builder jarPaths(String... jarPaths)
jarPaths
and returns a reference to this Builder enabling method
chaining.jarPaths
- The jarPaths
to set.public FlinkContainersSettings.Builder jarPaths(Collection<String> jarPaths)
jarPaths
and returns a reference to this Builder enabling method
chaining.jarPaths
- The jarPaths
to set.public <T> FlinkContainersSettings.Builder setConfigOption(ConfigOption<T> option, T value)
T
- The type parameter.option
- The option.value
- The value.public FlinkContainersSettings.Builder setLogProperty(String key, String value)
key
- The property key.value
- The property value.public <T> FlinkContainersSettings.Builder basedOn(Configuration config)
config
with the default config, potentially overwriting the
defaults in case of collisions. Returns a reference to this Builder enabling method
chaining.T
- the type parameterconfig
- The config
to add.public <T> FlinkContainersSettings.Builder fullConfiguration(Configuration config)
flinkConfiguration
value to config
and returns a reference to
this Builder enabling method chaining.T
- the type parameterconfig
- The config
to set.public FlinkContainersSettings.Builder taskManagerHostnamePrefix(String taskManagerHostnamePrefix)
taskManagerHostnamePrefix
and returns a reference to this Builder
enabling method chaining.taskManagerHostnamePrefix
- The taskManagerHostnamePrefix
to set.public FlinkContainersSettings.Builder jobManagerHostname(String jobManagerHostname)
jobManagerHostname
- The job manager hostname to set.public FlinkContainersSettings build()
FlinkContainersConfig
built from the parameters previously set.FlinkContainersConfig
built with parameters of this FlinkContainersConfig.Builder
.Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.