Uses of Class
org.apache.flink.kubernetes.operator.api.spec.AbstractFlinkSpec
-
-
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. -
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>
booleanReconciliationUtils. applyValidationErrorAndResetSpec(AbstractFlinkResource<SPEC,?> deployment, java.lang.String validationError, FlinkOperatorConfiguration conf)
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>
SPECReconciliationUtils. 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>
voidReconciliationUtils. updateLastReconciledSavepointTriggerNonce(SavepointInfo savepointInfo, AbstractFlinkResource<SPEC,?> target)
static <SPEC extends AbstractFlinkSpec>
voidReconciliationUtils. updateStatusBeforeDeploymentAttempt(AbstractFlinkResource<SPEC,?> target, org.apache.flink.configuration.Configuration conf)
Update status before deployment attempt of a new resource spec.static <SPEC extends AbstractFlinkSpec>
voidReconciliationUtils. updateStatusForAlreadyUpgraded(AbstractFlinkResource<SPEC,?> resource)
Updates status in cases where a previously successful deployment wasn't recorded for any reason.static <SPEC extends AbstractFlinkSpec>
voidReconciliationUtils. updateStatusForDeployedSpec(AbstractFlinkResource<SPEC,?> target, org.apache.flink.configuration.Configuration conf)
Update status after successful deployment of a new resource spec. -
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.
-