Uses of Class
org.apache.flink.kubernetes.operator.api.spec.AbstractFlinkSpec

Packages that use AbstractFlinkSpec

Package	Description
org.apache.flink.kubernetes.operator.api
org.apache.flink.kubernetes.operator.api.spec
org.apache.flink.kubernetes.operator.api.status
org.apache.flink.kubernetes.operator.api.utils
org.apache.flink.kubernetes.operator.controller
org.apache.flink.kubernetes.operator.reconciler
org.apache.flink.kubernetes.operator.reconciler.deployment

Uses of AbstractFlinkSpec in org.apache.flink.kubernetes.operator.api

Classes in org.apache.flink.kubernetes.operator.api with type parameters of type AbstractFlinkSpec

Modifier and Type	Class	Description
class	AbstractFlinkResource<SPEC extends AbstractFlinkSpec,STATUS extends CommonStatus<SPEC>>	Abstract base class Flink resources.

Uses of AbstractFlinkSpec in org.apache.flink.kubernetes.operator.api.spec

Subclasses of AbstractFlinkSpec in org.apache.flink.kubernetes.operator.api.spec

Modifier and Type	Class	Description
class	FlinkDeploymentSpec	Spec that describes a Flink application or session cluster deployment.
class	FlinkSessionJobSpec	Spec that describes a Flink session job.

Uses of AbstractFlinkSpec in org.apache.flink.kubernetes.operator.api.status

Classes in org.apache.flink.kubernetes.operator.api.status with type parameters of type AbstractFlinkSpec

Modifier and Type	Class	Description
class	CommonStatus<SPEC extends AbstractFlinkSpec>	Last observed common status of the Flink deployment/Flink SessionJob.
class	ReconciliationStatus<SPEC extends AbstractFlinkSpec>	Status of the last reconcile step for the FlinkDeployment/FlinkSessionJob.

Uses of AbstractFlinkSpec in org.apache.flink.kubernetes.operator.api.utils

Classes in org.apache.flink.kubernetes.operator.api.utils with type parameters of type AbstractFlinkSpec

Modifier and Type	Class	Description
class	SpecWithMeta<T extends AbstractFlinkSpec>	Utility class for encapsulating Kubernetes resource spec and meta fields during serialization.

Methods in org.apache.flink.kubernetes.operator.api.utils with type parameters of type AbstractFlinkSpec

Modifier and Type	Method	Description
static <T extends AbstractFlinkSpec> SpecWithMeta<T>	SpecUtils.deserializeSpecWithMeta(java.lang.String specWithMetaString, java.lang.Class<T> specClass)	Deserializes the spec and custom metadata object from JSON.

Methods in org.apache.flink.kubernetes.operator.api.utils with parameters of type AbstractFlinkSpec

Modifier and Type	Method	Description
static java.lang.String	SpecUtils.writeSpecWithMeta(AbstractFlinkSpec spec, AbstractFlinkResource<?,?> relatedResource)	Serializes the spec and custom meta information into a JSON string.
static java.lang.String	SpecUtils.writeSpecWithMeta(AbstractFlinkSpec spec, ReconciliationMetadata metadata)	Serializes the spec and custom meta information into a JSON string.

Method parameters in org.apache.flink.kubernetes.operator.api.utils with type arguments of type AbstractFlinkSpec

Modifier and Type	Method	Description
static JobSpec	FlinkResourceUtils.getJobSpec(AbstractFlinkResource<? extends AbstractFlinkSpec,? extends CommonStatus<?>> deployment)

Uses of AbstractFlinkSpec in org.apache.flink.kubernetes.operator.controller

Methods in org.apache.flink.kubernetes.operator.controller with parameters of type AbstractFlinkSpec

Modifier and Type	Method	Description
org.apache.flink.configuration.Configuration	FlinkDeploymentContext.getDeployConfig(AbstractFlinkSpec spec)
abstract org.apache.flink.configuration.Configuration	FlinkResourceContext.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).
org.apache.flink.configuration.Configuration	FlinkSessionJobContext.getDeployConfig(AbstractFlinkSpec spec)

Uses of AbstractFlinkSpec in org.apache.flink.kubernetes.operator.reconciler

Methods in org.apache.flink.kubernetes.operator.reconciler with type parameters of type AbstractFlinkSpec

Modifier and Type	Method	Description
static <SPEC extends AbstractFlinkSpec> boolean	ReconciliationUtils.applyValidationErrorAndResetSpec(FlinkResourceContext<? extends AbstractFlinkResource<SPEC,?>> ctx, java.lang.String validationError)	In case of validation errors we need to (temporarily) reset the old spec so that we can reconcile other outstanding changes, instead of simply blocking.
static <SPEC extends AbstractFlinkSpec> SPEC	ReconciliationUtils.getDeployedSpec(AbstractFlinkResource<SPEC,?> deployment)
static <SPEC extends AbstractFlinkSpec,STATUS extends CommonStatus<SPEC>,R extends io.fabric8.kubernetes.client.CustomResource<SPEC,STATUS>> io.javaoperatorsdk.operator.api.reconciler.UpdateControl<R>	ReconciliationUtils.toUpdateControl(FlinkOperatorConfiguration operatorConfiguration, R current, R previous, boolean reschedule)
static <SPEC extends AbstractFlinkSpec> void	ReconciliationUtils.updateLastReconciledSnapshotTriggerNonce(SnapshotTriggerType snapshotTriggerType, AbstractFlinkResource<SPEC,?> target, SnapshotType snapshotType)
static <T extends AbstractFlinkSpec> void	ReconciliationUtils.updateLastReconciledSpec(AbstractFlinkResource<T,?> resource, java.util.function.BiConsumer<T,ReconciliationMetadata> update)
static <SPEC extends AbstractFlinkSpec> void	ReconciliationUtils.updateReconciliationMetadata(AbstractFlinkResource<SPEC,?> resource)
static <SPEC extends AbstractFlinkSpec> void	ReconciliationUtils.updateStatusBeforeDeploymentAttempt(AbstractFlinkResource<SPEC,?> target, org.apache.flink.configuration.Configuration conf)
static <SPEC extends AbstractFlinkSpec> void	ReconciliationUtils.updateStatusBeforeDeploymentAttempt(AbstractFlinkResource<SPEC,?> target, org.apache.flink.configuration.Configuration conf, java.time.Clock clock)	Update status before deployment attempt of a new resource spec.
static <SPEC extends AbstractFlinkSpec> void	ReconciliationUtils.updateStatusForDeployedSpec(AbstractFlinkResource<SPEC,?> target, org.apache.flink.configuration.Configuration conf)
static <SPEC extends AbstractFlinkSpec> void	ReconciliationUtils.updateStatusForDeployedSpec(AbstractFlinkResource<SPEC,?> target, org.apache.flink.configuration.Configuration conf, java.time.Clock clock)	Update status after successful deployment of a new resource spec.
static <SPEC extends AbstractFlinkSpec> void	ReconciliationUtils.updateStatusForSpecReconciliation(AbstractFlinkResource<SPEC,?> target, JobState stateAfterReconcile, org.apache.flink.configuration.Configuration conf, boolean upgrading, java.time.Clock clock)

Uses of AbstractFlinkSpec in org.apache.flink.kubernetes.operator.reconciler.deployment

Classes in org.apache.flink.kubernetes.operator.reconciler.deployment with type parameters of type AbstractFlinkSpec

Modifier and Type	Class	Description
class	AbstractFlinkResourceReconciler<CR extends AbstractFlinkResource<SPEC,STATUS>,SPEC extends AbstractFlinkSpec,STATUS extends CommonStatus<SPEC>>	Base class for all Flink resource reconcilers.
class	AbstractJobReconciler<CR extends AbstractFlinkResource<SPEC,STATUS>,SPEC extends AbstractFlinkSpec,STATUS extends CommonStatus<SPEC>>	Reconciler responsible for handling the job lifecycle according to the desired and current states.