Class FlinkConfigBuilder
- java.lang.Object
-
- org.apache.flink.kubernetes.operator.config.FlinkConfigBuilder
-
public class FlinkConfigBuilder extends java.lang.Object
Builder to get effective flink config fromFlinkDeployment
.
-
-
Field Summary
Fields Modifier and Type Field Description protected static java.time.Duration
DEFAULT_CHECKPOINTING_INTERVAL
static org.apache.flink.configuration.ConfigOption<FlinkVersion>
FLINK_VERSION
protected static java.lang.String
GENERATED_FILE_PREFIX
-
Constructor Summary
Constructors Modifier Constructor Description protected
FlinkConfigBuilder(java.lang.String namespace, java.lang.String clusterId, FlinkDeploymentSpec spec, org.apache.flink.configuration.Configuration flinkConfig)
protected
FlinkConfigBuilder(FlinkDeployment deployment, org.apache.flink.configuration.Configuration flinkConfig)
-
Method Summary
All Methods Static Methods Instance Methods Concrete Methods Modifier and Type Method Description protected FlinkConfigBuilder
applyCommonPodTemplate()
protected FlinkConfigBuilder
applyFlinkConfiguration()
protected FlinkConfigBuilder
applyImage()
protected FlinkConfigBuilder
applyImagePullPolicy()
protected FlinkConfigBuilder
applyIngressDomain()
protected FlinkConfigBuilder
applyJobManagerSpec()
protected FlinkConfigBuilder
applyJobOrSessionSpec()
protected FlinkConfigBuilder
applyLogConfiguration()
protected FlinkConfigBuilder
applyServiceAccount()
protected FlinkConfigBuilder
applyTaskManagerSpec()
protected org.apache.flink.configuration.Configuration
build()
static org.apache.flink.configuration.Configuration
buildFrom(java.lang.String namespace, java.lang.String clusterId, FlinkDeploymentSpec spec, org.apache.flink.configuration.Configuration flinkConfig)
protected static void
cleanupTmpFiles(org.apache.flink.configuration.Configuration configuration)
-
-
-
Field Detail
-
FLINK_VERSION
public static final org.apache.flink.configuration.ConfigOption<FlinkVersion> FLINK_VERSION
-
GENERATED_FILE_PREFIX
protected static final java.lang.String GENERATED_FILE_PREFIX
- See Also:
- Constant Field Values
-
DEFAULT_CHECKPOINTING_INTERVAL
protected static final java.time.Duration DEFAULT_CHECKPOINTING_INTERVAL
-
-
Constructor Detail
-
FlinkConfigBuilder
protected FlinkConfigBuilder(FlinkDeployment deployment, org.apache.flink.configuration.Configuration flinkConfig)
-
FlinkConfigBuilder
protected FlinkConfigBuilder(java.lang.String namespace, java.lang.String clusterId, FlinkDeploymentSpec spec, org.apache.flink.configuration.Configuration flinkConfig)
-
-
Method Detail
-
applyImage
protected FlinkConfigBuilder applyImage()
-
applyImagePullPolicy
protected FlinkConfigBuilder applyImagePullPolicy()
-
applyFlinkConfiguration
protected FlinkConfigBuilder applyFlinkConfiguration()
-
applyLogConfiguration
protected FlinkConfigBuilder applyLogConfiguration() throws java.io.IOException
- Throws:
java.io.IOException
-
applyCommonPodTemplate
protected FlinkConfigBuilder applyCommonPodTemplate() throws java.io.IOException
- Throws:
java.io.IOException
-
applyIngressDomain
protected FlinkConfigBuilder applyIngressDomain()
-
applyServiceAccount
protected FlinkConfigBuilder applyServiceAccount()
-
applyJobManagerSpec
protected FlinkConfigBuilder applyJobManagerSpec() throws java.io.IOException
- Throws:
java.io.IOException
-
applyTaskManagerSpec
protected FlinkConfigBuilder applyTaskManagerSpec() throws java.io.IOException
- Throws:
java.io.IOException
-
applyJobOrSessionSpec
protected FlinkConfigBuilder applyJobOrSessionSpec() throws java.net.URISyntaxException
- Throws:
java.net.URISyntaxException
-
build
protected org.apache.flink.configuration.Configuration build()
-
buildFrom
public static org.apache.flink.configuration.Configuration buildFrom(java.lang.String namespace, java.lang.String clusterId, FlinkDeploymentSpec spec, org.apache.flink.configuration.Configuration flinkConfig) throws java.io.IOException, java.net.URISyntaxException
- Throws:
java.io.IOException
java.net.URISyntaxException
-
cleanupTmpFiles
protected static void cleanupTmpFiles(org.apache.flink.configuration.Configuration configuration)
-
-