Uses of Class
org.apache.flink.kubernetes.operator.api.AbstractFlinkResource
-
-
Uses of AbstractFlinkResource in org.apache.flink.kubernetes.operator.api
Subclasses of AbstractFlinkResource in org.apache.flink.kubernetes.operator.api Modifier and Type Class Description class
FlinkDeployment
Custom resource definition that represents both Application and Session deployments.class
FlinkSessionJob
Custom resource definition that represents a flink session job. -
Uses of AbstractFlinkResource in org.apache.flink.kubernetes.operator.api.listener
Classes in org.apache.flink.kubernetes.operator.api.listener with type parameters of type AbstractFlinkResource Modifier and Type Interface Description static interface
FlinkResourceListener.ResourceContext<R extends AbstractFlinkResource<?,?>>
Base for Resource Event and StatusUpdate contexts.static interface
FlinkResourceListener.ResourceEventContext<R extends AbstractFlinkResource<?,?>>
Context for Resource Event listener methods.static interface
FlinkResourceListener.StatusUpdateContext<R extends AbstractFlinkResource<?,S>,S extends CommonStatus<?>>
Context for Status listener methods. -
Uses of AbstractFlinkResource in org.apache.flink.kubernetes.operator.api.reconciler
Methods in org.apache.flink.kubernetes.operator.api.reconciler with parameters of type AbstractFlinkResource Modifier and Type Method Description static ReconciliationMetadata
ReconciliationMetadata. from(AbstractFlinkResource<?,?> resource)
-
Uses of AbstractFlinkResource in org.apache.flink.kubernetes.operator.api.status
Methods in org.apache.flink.kubernetes.operator.api.status with parameters of type AbstractFlinkResource Modifier and Type Method Description void
ReconciliationStatus. serializeAndSetLastReconciledSpec(SPEC spec, AbstractFlinkResource<SPEC,?> resource)
-
Uses of AbstractFlinkResource in org.apache.flink.kubernetes.operator.api.utils
Methods in org.apache.flink.kubernetes.operator.api.utils with parameters of type AbstractFlinkResource 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. -
Uses of AbstractFlinkResource in org.apache.flink.kubernetes.operator.listener
Methods in org.apache.flink.kubernetes.operator.listener with type parameters of type AbstractFlinkResource Modifier and Type Method Description static <R extends AbstractFlinkResource<?,?>>
voidAuditUtils. logContext(FlinkResourceListener.ResourceEventContext<R> ctx)
static <R extends AbstractFlinkResource<?,S>,S extends CommonStatus<?>>
voidAuditUtils. logContext(FlinkResourceListener.StatusUpdateContext<R,S> ctx)
-
Uses of AbstractFlinkResource in org.apache.flink.kubernetes.operator.metrics
Classes in org.apache.flink.kubernetes.operator.metrics with type parameters of type AbstractFlinkResource Modifier and Type Class Description class
MetricManager<CR extends AbstractFlinkResource<?,?>>
Metric manager for Operator managed custom resources.Method parameters in org.apache.flink.kubernetes.operator.metrics with type arguments of type AbstractFlinkResource Modifier and Type Method Description KubernetesResourceNamespaceMetricGroup
KubernetesOperatorMetricGroup. createResourceNamespaceGroup(org.apache.flink.configuration.Configuration config, java.lang.Class<? extends AbstractFlinkResource> resourceClass, java.lang.String resourceNs)
-
Uses of AbstractFlinkResource in org.apache.flink.kubernetes.operator.metrics.lifecycle
Classes in org.apache.flink.kubernetes.operator.metrics.lifecycle with type parameters of type AbstractFlinkResource Modifier and Type Class Description class
LifecycleMetrics<CR extends AbstractFlinkResource<?,?>>
Utility for tracking resource lifecycle metrics globally and per namespace. -
Uses of AbstractFlinkResource in org.apache.flink.kubernetes.operator.observer
Classes in org.apache.flink.kubernetes.operator.observer with type parameters of type AbstractFlinkResource Modifier and Type Class Description class
AbstractFlinkResourceObserver<CR extends AbstractFlinkResource<?,?>,CTX extends ObserverContext>
Base observer for all Flink resources.class
JobStatusObserver<R extends AbstractFlinkResource<?,?>,CTX extends ObserverContext>
An observer to observe the job status.class
SavepointObserver<CR extends AbstractFlinkResource<?,STATUS>,STATUS extends CommonStatus<?>>
An observer of savepoint progress. -
Uses of AbstractFlinkResource in org.apache.flink.kubernetes.operator.reconciler
Methods in org.apache.flink.kubernetes.operator.reconciler with type parameters of type AbstractFlinkResource Modifier and Type Method Description static <STATUS extends CommonStatus<?>,R extends AbstractFlinkResource<?,STATUS>>
io.javaoperatorsdk.operator.api.reconciler.ErrorStatusUpdateControl<R>ReconciliationUtils. toErrorStatusUpdateControl(R resource, java.util.Optional<io.javaoperatorsdk.operator.api.reconciler.RetryInfo> retryInfo, java.lang.Exception e, StatusRecorder<R,STATUS> statusRecorder, FlinkOperatorConfiguration operatorConfiguration)
Update the resource error status and metrics when the operator encountered an exception during reconciliation.Methods in org.apache.flink.kubernetes.operator.reconciler with parameters of type AbstractFlinkResource 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 void
ReconciliationUtils. clearLastReconciledSpecIfFirstDeploy(AbstractFlinkResource<?,?> resource)
Clear last reconciled spec if that corresponds to the first deployment.static <SPEC extends AbstractFlinkSpec>
SPECReconciliationUtils. getDeployedSpec(AbstractFlinkResource<SPEC,?> deployment)
static java.lang.Long
ReconciliationUtils. getUpgradeTargetGeneration(AbstractFlinkResource<?,?> resource)
Get spec generation for the current in progress upgrade.static boolean
ReconciliationUtils. isUpgradeModeChangedToLastStateAndHADisabledPreviously(AbstractFlinkResource<?,?> flinkApp, org.apache.flink.configuration.Configuration observeConfig)
static void
ReconciliationUtils. updateForReconciliationError(AbstractFlinkResource<?,?> target, java.lang.Throwable error, FlinkOperatorConfiguration conf)
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 AbstractFlinkResource in org.apache.flink.kubernetes.operator.reconciler.deployment
Classes in org.apache.flink.kubernetes.operator.reconciler.deployment with type parameters of type AbstractFlinkResource 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. -
Uses of AbstractFlinkResource in org.apache.flink.kubernetes.operator.utils
Classes in org.apache.flink.kubernetes.operator.utils with type parameters of type AbstractFlinkResource Modifier and Type Class Description class
StatusRecorder<CR extends AbstractFlinkResource<?,STATUS>,STATUS extends CommonStatus<?>>
Helper class for status management and updates.Methods in org.apache.flink.kubernetes.operator.utils with type parameters of type AbstractFlinkResource Modifier and Type Method Description static <S extends CommonStatus<?>,CR extends AbstractFlinkResource<?,S>>
StatusRecorder<CR,S>StatusRecorder. create(io.fabric8.kubernetes.client.KubernetesClient kubernetesClient, MetricManager<CR> metricManager, java.util.Collection<FlinkResourceListener> listeners)
static <R extends AbstractFlinkResource>
voidFlinkResourceExceptionUtils. updateFlinkResourceException(java.lang.Throwable throwable, R resource, FlinkOperatorConfiguration conf)
Methods in org.apache.flink.kubernetes.operator.utils with parameters of type AbstractFlinkResource Modifier and Type Method Description static SavepointStatus
SavepointUtils. getLastSavepointStatus(AbstractFlinkResource<?,?> resource)
static void
SavepointUtils. resetTriggerIfJobNotRunning(AbstractFlinkResource<?,?> resource, EventRecorder eventRecorder)
protected static java.util.Optional<SavepointTriggerType>
SavepointUtils. shouldTriggerSavepoint(AbstractFlinkResource<?,?> resource, org.apache.flink.configuration.Configuration conf)
Checks whether savepoint should be triggered based on the current status and spec and if yes, returns the correctSavepointTriggerType
.boolean
EventRecorder. triggerEvent(AbstractFlinkResource<?,?> resource, EventRecorder.Type type, java.lang.String reason, java.lang.String message, EventRecorder.Component component)
boolean
EventRecorder. triggerEvent(AbstractFlinkResource<?,?> resource, EventRecorder.Type type, EventRecorder.Reason reason, EventRecorder.Component component, java.lang.String message)
static boolean
SavepointUtils. triggerSavepointIfNeeded(FlinkService flinkService, AbstractFlinkResource<?,?> resource, org.apache.flink.configuration.Configuration conf)
Triggers any pending manual or periodic savepoints and updates the status accordingly.Constructor parameters in org.apache.flink.kubernetes.operator.utils with type arguments of type AbstractFlinkResource Constructor Description EventRecorder(io.fabric8.kubernetes.client.KubernetesClient client, java.util.function.BiConsumer<AbstractFlinkResource<?,?>,io.fabric8.kubernetes.api.model.Event> eventListener)
-