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

Class FlinkResourceContext<CR extends AbstractFlinkResource<?,?>>

java.lang.Object

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

Direct Known Subclasses:

FlinkDeploymentContext, FlinkSessionJobContext

public abstract class FlinkResourceContext<CR extends AbstractFlinkResource<?,?>>
extends java.lang.Object

Context for reconciling a Flink resource. *

Constructor Summary

Constructors

Constructor	Description
FlinkResourceContext()

Method Summary

Modifier and Type	Method	Description
protected abstract org.apache.flink.configuration.Configuration	createObserveConfig()	Generate the config that is currently deployed for the resource spec.
abstract 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).
abstract FlinkService	getFlinkService()	Get the FlinkService implementation for the current resource.
org.apache.flink.configuration.Configuration	getObserveConfig()	Get the config that is currently deployed for the resource spec.

Methods inherited from class java.lang.Object

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

Constructor Detail

FlinkResourceContext

public FlinkResourceContext()

Method Detail

getObserveConfig

public org.apache.flink.configuration.Configuration getObserveConfig()

Get the config that is currently deployed for the resource spec. The returned config may be null in case the resource is not accessible/ready yet.

Returns:

Config currently deployed.

getDeployConfig

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

Parameters:

spec - Spec for which the config should be created.

Returns:

Deployment configuration.

getFlinkService

public abstract FlinkService getFlinkService()

Get the FlinkService implementation for the current resource.

Returns:

Flink service.

createObserveConfig

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

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

Returns:

Deployed config.