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. *

Constructor Summary

Constructors

Constructor	Description
FlinkDeploymentContext(FlinkDeployment resource, io.javaoperatorsdk.operator.api.reconciler.Context<?> josdkContext, KubernetesResourceMetricGroup resourceMetricGroup, FlinkService flinkService, FlinkConfigManager configManager)

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

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

getFlinkService, getObserveConfig

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,
                              FlinkService flinkService,
                              FlinkConfigManager configManager)

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.