Package org.apache.flink.kubernetes.operator.controller

Class FlinkDeploymentContext

java.lang.Object

org.apache.flink.kubernetes.operator.controller.FlinkResourceContext<org.apache.flink.kubernetes.operator.api.FlinkDeployment>

org.apache.flink.kubernetes.operator.controller.FlinkDeploymentContext

public class FlinkDeploymentContext
extends FlinkResourceContext<org.apache.flink.kubernetes.operator.api.FlinkDeployment>

Context for reconciling a Flink resource.

Field Summary

Fields inherited from class org.apache.flink.kubernetes.operator.controller.FlinkResourceContext

configManager

Constructor Summary

Constructors

Constructor	Description
FlinkDeploymentContext(org.apache.flink.kubernetes.operator.api.FlinkDeployment resource, io.javaoperatorsdk.operator.api.reconciler.Context<?> josdkContext, KubernetesResourceMetricGroup resourceMetricGroup, FlinkConfigManager configManager, java.util.function.Function<FlinkResourceContext<?>,FlinkService> flinkServiceFactory)

Method Summary

Modifier and Type	Method	Description
protected org.apache.flink.configuration.Configuration	createObserveConfig()	Generate the config that is currently deployed for the resource spec.
org.apache.flink.configuration.Configuration	getDeployConfig(org.apache.flink.kubernetes.operator.api.spec.AbstractFlinkSpec spec)	Get Flink configuration object for deploying the given spec using AbstractFlinkResourceReconciler.deploy(org.apache.flink.kubernetes.operator.controller.FlinkResourceContext<CR>, SPEC, org.apache.flink.configuration.Configuration, java.util.Optional<java.lang.String>, boolean).
org.apache.flink.kubernetes.operator.api.spec.KubernetesDeploymentMode	getDeploymentMode()
org.apache.flink.kubernetes.operator.api.spec.FlinkVersion	getFlinkVersion()

Methods inherited from class org.apache.flink.kubernetes.operator.controller.FlinkResourceContext

createFlinkService, getFlinkService, getJobAutoScalerContext, getKubernetesClient, getObserveConfig, getOperatorConfig

Methods inherited from class java.lang.Object

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

Constructor Detail

FlinkDeploymentContext

public FlinkDeploymentContext(org.apache.flink.kubernetes.operator.api.FlinkDeployment resource,
                              io.javaoperatorsdk.operator.api.reconciler.Context<?> josdkContext,
                              KubernetesResourceMetricGroup resourceMetricGroup,
                              FlinkConfigManager configManager,
                              java.util.function.Function<FlinkResourceContext<?>,FlinkService> flinkServiceFactory)

Method Detail

getDeployConfig

public org.apache.flink.configuration.Configuration getDeployConfig(org.apache.flink.kubernetes.operator.api.spec.AbstractFlinkSpec spec)

Description copied from class: FlinkResourceContext

Get Flink configuration object for deploying the given spec using AbstractFlinkResourceReconciler.deploy(org.apache.flink.kubernetes.operator.controller.FlinkResourceContext<CR>, SPEC, org.apache.flink.configuration.Configuration, java.util.Optional<java.lang.String>, boolean).

Specified by:

getDeployConfig in class FlinkResourceContext<org.apache.flink.kubernetes.operator.api.FlinkDeployment>

Parameters:

spec - Spec for which the config should be created.

Returns:

Deployment configuration.

createObserveConfig

protected org.apache.flink.configuration.Configuration createObserveConfig()

Description copied from class: FlinkResourceContext

Generate the config that is currently deployed for the resource spec.

Specified by:

createObserveConfig in class FlinkResourceContext<org.apache.flink.kubernetes.operator.api.FlinkDeployment>

Returns:

Deployed config.

getDeploymentMode

public org.apache.flink.kubernetes.operator.api.spec.KubernetesDeploymentMode getDeploymentMode()

Specified by:

getDeploymentMode in class FlinkResourceContext<org.apache.flink.kubernetes.operator.api.FlinkDeployment>

Returns:

Cluster deployment mode.

getFlinkVersion

public org.apache.flink.kubernetes.operator.api.spec.FlinkVersion getFlinkVersion()

Specified by:

getFlinkVersion in class FlinkResourceContext<org.apache.flink.kubernetes.operator.api.FlinkDeployment>

Returns:

Cluster Flink Version.