public class ContainerSpecification extends Object implements Serializable
The specification is mutable.
Note that the Flink configuration settings are considered dynamic overrides of whatever static configuration file is present in the container. For example, a container might be based on a Docker image with a normal Flink installation with customized settings, which these settings would (partially) override.
Artifacts are copied into a sandbox directory within the container, which any Flink process launched in the container is assumed to use as a working directory. This assumption allows for relative paths to be used in certain environment variables.
Modifier and Type | Class and Description |
---|---|
static class |
ContainerSpecification.Artifact
An artifact to be copied into the container.
|
Constructor and Description |
---|
ContainerSpecification() |
Modifier and Type | Method and Description |
---|---|
static String |
createDynamicProperty(String key,
String value)
Create a dynamic property from the given key and value of the format
-Dkey=value . |
static String |
formatSystemProperties(Configuration jvmArgs)
Format the system properties as a shell-compatible command-line argument.
|
static ContainerSpecification |
from(Configuration flinkConfiguration) |
List<ContainerSpecification.Artifact> |
getArtifacts()
Get the container artifacts.
|
Map<String,String> |
getEnvironmentVariables()
Get the environment variables.
|
Configuration |
getFlinkConfiguration()
Get the dynamic configuration.
|
Configuration |
getSystemProperties()
Get the system properties.
|
String |
toString() |
public List<ContainerSpecification.Artifact> getArtifacts()
public Map<String,String> getEnvironmentVariables()
public Configuration getFlinkConfiguration()
public Configuration getSystemProperties()
public static ContainerSpecification from(Configuration flinkConfiguration)
public static String formatSystemProperties(Configuration jvmArgs)
Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.