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

Class FlinkDeploymentContext

java.lang.Object

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

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

public class FlinkDeploymentContext
extends FlinkResourceContext<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(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(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).
KubernetesDeploymentMode	getDeploymentMode()
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(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(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<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<FlinkDeployment>

Returns:

Deployed config.

getDeploymentMode

public KubernetesDeploymentMode getDeploymentMode()

Specified by:

getDeploymentMode in class FlinkResourceContext<FlinkDeployment>

Returns:

Cluster deployment mode.

getFlinkVersion

public FlinkVersion getFlinkVersion()

Specified by:

getFlinkVersion in class FlinkResourceContext<FlinkDeployment>

Returns:

Cluster Flink Version.