Package org.apache.flink.kubernetes.operator.config

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 from FlinkDeployment.

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 flinkConf)
protected	FlinkConfigBuilder(FlinkDeployment deployment, org.apache.flink.configuration.Configuration flinkConf)

Method Summary

Modifier and Type	Method	Description
protected FlinkConfigBuilder	applyFlinkConfiguration()
protected FlinkConfigBuilder	applyImage()
protected FlinkConfigBuilder	applyImagePullPolicy()
protected FlinkConfigBuilder	applyIngressDomain()
protected FlinkConfigBuilder	applyJobManagerSpec()
protected FlinkConfigBuilder	applyJobOrSessionSpec()
protected FlinkConfigBuilder	applyLogConfiguration()
protected FlinkConfigBuilder	applyPodTemplate()
protected static io.fabric8.kubernetes.api.model.PodTemplateSpec	applyResourceToPodTemplate(io.fabric8.kubernetes.api.model.PodTemplateSpec podTemplate, Resource resource)
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)
static java.lang.String	parseResourceMemoryString(java.lang.String memory)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

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 flinkConf)

FlinkConfigBuilder

protected FlinkConfigBuilder(java.lang.String namespace,
                             java.lang.String clusterId,
                             FlinkDeploymentSpec spec,
                             org.apache.flink.configuration.Configuration flinkConf)

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

applyPodTemplate

protected FlinkConfigBuilder applyPodTemplate()
                                       throws java.io.IOException

Throws:

java.io.IOException

applyIngressDomain

protected FlinkConfigBuilder applyIngressDomain()

applyServiceAccount

protected FlinkConfigBuilder applyServiceAccount()

applyJobManagerSpec

protected FlinkConfigBuilder applyJobManagerSpec()

applyTaskManagerSpec

protected FlinkConfigBuilder applyTaskManagerSpec()

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

parseResourceMemoryString

public static java.lang.String parseResourceMemoryString(java.lang.String memory)

applyResourceToPodTemplate

@VisibleForTesting
protected static io.fabric8.kubernetes.api.model.PodTemplateSpec applyResourceToPodTemplate(io.fabric8.kubernetes.api.model.PodTemplateSpec podTemplate,
                                                                                            Resource resource)

cleanupTmpFiles

protected static void cleanupTmpFiles(org.apache.flink.configuration.Configuration configuration)