public class FlinkContainersSettings extends Object
Modifier and Type | Class and Description |
---|---|
static class |
FlinkContainersSettings.Builder
FlinkContainersConfig builder static inner class. |
Modifier and Type | Method and Description |
---|---|
static FlinkContainersSettings |
basedOn(Configuration config)
FlinkContainersConfig based on provided Flink configuration. |
static FlinkContainersSettings.Builder |
builder()
A new builder for
FlinkContainersConfig . |
static FlinkContainersSettings |
defaultConfig()
FlinkContainersConfig based on defaults. |
String |
getBaseImage()
Gets base image.
|
String |
getCheckpointPath()
Gets checkpoint path.
|
static String |
getDefaultCheckpointPath()
Gets default checkpoint path.
|
static String |
getDefaultFlinkHome()
Gets default flink home.
|
Configuration |
getFlinkConfig()
Gets flink configuration.
|
String |
getFlinkDistLocation()
Gets flink dist location.
|
String |
getFlinkHome()
Gets flink home.
|
String |
getHaStoragePath()
Gets HA storage path.
|
String |
getHaStoragePathUri()
Gets ha storage path uri.
|
Collection<String> |
getJarPaths()
Gets jar paths.
|
String |
getJobManagerHostname()
Gets job manager hostname.
|
Properties |
getLogProperties()
Gets logging properties.
|
int |
getNumSlotsPerTaskManager()
Gets number slots per task manager.
|
int |
getNumTaskManagers()
Gets number of task managers.
|
String |
getTaskManagerHostnamePrefix()
Gets task manager hostname prefix.
|
String |
getZookeeperHostname()
Gets Zookeeper hostname.
|
Boolean |
isBuildFromFlinkDist()
Returns whether to build from flink-dist or from an existing base container.
|
Boolean |
isZookeeperHA()
Is zookeeper HA boolean.
|
public static FlinkContainersSettings.Builder builder()
FlinkContainersConfig
.public static FlinkContainersSettings defaultConfig()
FlinkContainersConfig
based on defaults.public static FlinkContainersSettings basedOn(Configuration config)
FlinkContainersConfig
based on provided Flink configuration.config
- The config.public String getBaseImage()
public int getNumTaskManagers()
public int getNumSlotsPerTaskManager()
public Collection<String> getJarPaths()
public Configuration getFlinkConfig()
public String getTaskManagerHostnamePrefix()
public String getJobManagerHostname()
public Boolean isBuildFromFlinkDist()
baseImage
property.public String getFlinkDistLocation()
public String getFlinkHome()
public String getCheckpointPath()
public String getHaStoragePath()
public String getHaStoragePathUri()
public static String getDefaultFlinkHome()
public static String getDefaultCheckpointPath()
public Boolean isZookeeperHA()
public String getZookeeperHostname()
public Properties getLogProperties()
Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.