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

Class FlinkSessionJobContext

java.lang.Object

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

org.apache.flink.kubernetes.operator.controller.FlinkSessionJobContext

public class FlinkSessionJobContext
extends FlinkResourceContext<FlinkSessionJob>

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
FlinkSessionJobContext(FlinkSessionJob 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 FlinkService	createFlinkService()
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

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

FlinkSessionJobContext

public FlinkSessionJobContext(FlinkSessionJob 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<FlinkSessionJob>

Parameters:

spec - Spec for which the config should be created.

Returns:

Deployment configuration.

createFlinkService

protected FlinkService createFlinkService()

Overrides:

createFlinkService in class FlinkResourceContext<FlinkSessionJob>

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<FlinkSessionJob>

Returns:

Deployed config.

getDeploymentMode

public KubernetesDeploymentMode getDeploymentMode()

Specified by:

getDeploymentMode in class FlinkResourceContext<FlinkSessionJob>

Returns:

Cluster deployment mode.

getFlinkVersion

public FlinkVersion getFlinkVersion()

Specified by:

getFlinkVersion in class FlinkResourceContext<FlinkSessionJob>

Returns:

Cluster Flink Version.