Uses of Class
org.apache.flink.kubernetes.operator.api.status.CommonStatus
-
-
Uses of CommonStatus in org.apache.flink.kubernetes.operator.api
Classes in org.apache.flink.kubernetes.operator.api with type parameters of type CommonStatus Modifier and Type Class Description class
AbstractFlinkResource<SPEC extends AbstractFlinkSpec,STATUS extends CommonStatus<SPEC>>
Abstract base class Flink resources. -
Uses of CommonStatus in org.apache.flink.kubernetes.operator.api.listener
Classes in org.apache.flink.kubernetes.operator.api.listener with type parameters of type CommonStatus Modifier and Type Interface Description static interface
FlinkResourceListener.StatusUpdateContext<R extends AbstractFlinkResource<?,S>,S extends CommonStatus<?>>
Context for Status listener methods. -
Uses of CommonStatus in org.apache.flink.kubernetes.operator.api.status
Subclasses of CommonStatus in org.apache.flink.kubernetes.operator.api.status Modifier and Type Class Description class
FlinkDeploymentStatus
Last observed status of the Flink deployment.class
FlinkSessionJobStatus
Last observed status of the Flink Session job. -
Uses of CommonStatus in org.apache.flink.kubernetes.operator.api.utils
Method parameters in org.apache.flink.kubernetes.operator.api.utils with type arguments of type CommonStatus Modifier and Type Method Description static JobSpec
FlinkResourceUtils. getJobSpec(AbstractFlinkResource<? extends AbstractFlinkSpec,? extends CommonStatus<?>> deployment)
-
Uses of CommonStatus in org.apache.flink.kubernetes.operator.listener
Methods in org.apache.flink.kubernetes.operator.listener with type parameters of type CommonStatus Modifier and Type Method Description static <R extends AbstractFlinkResource<?,S>,S extends CommonStatus<?>>
voidAuditUtils. logContext(FlinkResourceListener.StatusUpdateContext<R,S> ctx)
-
Uses of CommonStatus in org.apache.flink.kubernetes.operator.observer
Classes in org.apache.flink.kubernetes.operator.observer with type parameters of type CommonStatus Modifier and Type Class Description class
SnapshotObserver<CR extends AbstractFlinkResource<?,STATUS>,STATUS extends CommonStatus<?>>
An observer of savepoint progress. -
Uses of CommonStatus in org.apache.flink.kubernetes.operator.reconciler
Methods in org.apache.flink.kubernetes.operator.reconciler with type parameters of type CommonStatus Modifier and Type Method Description static <STATUS extends CommonStatus<?>,R extends AbstractFlinkResource<?,STATUS>>
io.javaoperatorsdk.operator.api.reconciler.ErrorStatusUpdateControl<R>ReconciliationUtils. toErrorStatusUpdateControl(FlinkResourceContext<R> ctx, java.lang.Exception e, StatusRecorder<R,STATUS> statusRecorder)
Update the resource error status and metrics when the operator encountered an exception during reconciliation.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)
Methods in org.apache.flink.kubernetes.operator.reconciler with parameters of type CommonStatus Modifier and Type Method Description static void
ReconciliationUtils. checkAndUpdateStableSpec(CommonStatus<?> status)
Checks the status and if the corresponding Flink job/application is in stable running state, it updates the last stable spec.static boolean
ReconciliationUtils. isJobInTerminalState(CommonStatus<?> status)
static boolean
ReconciliationUtils. isJobRunning(CommonStatus<?> status)
-
Uses of CommonStatus in org.apache.flink.kubernetes.operator.reconciler.deployment
Classes in org.apache.flink.kubernetes.operator.reconciler.deployment with type parameters of type CommonStatus 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 CommonStatus in org.apache.flink.kubernetes.operator.utils
Classes in org.apache.flink.kubernetes.operator.utils with type parameters of type CommonStatus 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 CommonStatus 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)
-