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

Class FlinkSessionJobContext

java.lang.Object

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

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

public class FlinkSessionJobContext
extends FlinkResourceContext<org.apache.flink.kubernetes.operator.api.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(org.apache.flink.kubernetes.operator.api.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(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

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(org.apache.flink.kubernetes.operator.api.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(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.FlinkSessionJob>

Parameters:

spec - Spec for which the config should be created.

Returns:

Deployment configuration.

createFlinkService

protected FlinkService createFlinkService()

Overrides:

createFlinkService in class FlinkResourceContext<org.apache.flink.kubernetes.operator.api.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<org.apache.flink.kubernetes.operator.api.FlinkSessionJob>

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

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

Returns:

Cluster Flink Version.