Package | Description |
---|---|
org.apache.flink.connector.testframe.container |
Modifier and Type | Method and Description |
---|---|
<T> FlinkContainersSettings.Builder |
FlinkContainersSettings.Builder.basedOn(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(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(Collection<String> jarPaths)
Sets the
jarPaths 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.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(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 |
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. |
Copyright © 2014–2022 The Apache Software Foundation. All rights reserved.