Uses of Class
org.apache.flink.kubernetes.operator.utils.StatusRecorder

Packages that use StatusRecorder

Package	Description
org.apache.flink.kubernetes.operator.controller
org.apache.flink.kubernetes.operator.reconciler
org.apache.flink.kubernetes.operator.reconciler.deployment
org.apache.flink.kubernetes.operator.reconciler.sessionjob
org.apache.flink.kubernetes.operator.utils

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

Constructors in org.apache.flink.kubernetes.operator.controller with parameters of type StatusRecorder

Constructor	Description
FlinkDeploymentController(java.util.Set<FlinkResourceValidator> validators, FlinkResourceContextFactory ctxFactory, ReconcilerFactory reconcilerFactory, FlinkDeploymentObserverFactory observerFactory, StatusRecorder<org.apache.flink.kubernetes.operator.api.FlinkDeployment,org.apache.flink.kubernetes.operator.api.status.FlinkDeploymentStatus> statusRecorder, EventRecorder eventRecorder, CanaryResourceManager<org.apache.flink.kubernetes.operator.api.FlinkDeployment> canaryResourceManager)
FlinkSessionJobController(java.util.Set<FlinkResourceValidator> validators, FlinkResourceContextFactory ctxFactory, Reconciler<org.apache.flink.kubernetes.operator.api.FlinkSessionJob> reconciler, Observer<org.apache.flink.kubernetes.operator.api.FlinkSessionJob> observer, StatusRecorder<org.apache.flink.kubernetes.operator.api.FlinkSessionJob,org.apache.flink.kubernetes.operator.api.status.FlinkSessionJobStatus> statusRecorder, EventRecorder eventRecorder, CanaryResourceManager<org.apache.flink.kubernetes.operator.api.FlinkSessionJob> canaryResourceManager)

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

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

Modifier and Type	Method	Description
static <STATUS extends org.apache.flink.kubernetes.operator.api.status.CommonStatus<?>,R extends org.apache.flink.kubernetes.operator.api.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.

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

Fields in org.apache.flink.kubernetes.operator.reconciler.deployment declared as StatusRecorder

Modifier and Type	Field	Description
protected StatusRecorder<CR,STATUS>	AbstractFlinkResourceReconciler.statusRecorder

Constructors in org.apache.flink.kubernetes.operator.reconciler.deployment with parameters of type StatusRecorder

Constructor	Description
AbstractFlinkResourceReconciler(EventRecorder eventRecorder, StatusRecorder<CR,STATUS> statusRecorder, org.apache.flink.autoscaler.JobAutoScaler<io.javaoperatorsdk.operator.processing.event.ResourceID,KubernetesJobAutoScalerContext> autoscaler)
AbstractJobReconciler(EventRecorder eventRecorder, StatusRecorder<CR,STATUS> statusRecorder, org.apache.flink.autoscaler.JobAutoScaler<io.javaoperatorsdk.operator.processing.event.ResourceID,KubernetesJobAutoScalerContext> autoscaler)
ApplicationReconciler(EventRecorder eventRecorder, StatusRecorder<org.apache.flink.kubernetes.operator.api.FlinkDeployment,org.apache.flink.kubernetes.operator.api.status.FlinkDeploymentStatus> statusRecorder, org.apache.flink.autoscaler.JobAutoScaler<io.javaoperatorsdk.operator.processing.event.ResourceID,KubernetesJobAutoScalerContext> autoscaler)
ReconcilerFactory(EventRecorder eventRecorder, StatusRecorder<org.apache.flink.kubernetes.operator.api.FlinkDeployment,org.apache.flink.kubernetes.operator.api.status.FlinkDeploymentStatus> deploymentStatusRecorder, org.apache.flink.autoscaler.JobAutoScaler<io.javaoperatorsdk.operator.processing.event.ResourceID,KubernetesJobAutoScalerContext> autoscaler)
SessionReconciler(EventRecorder eventRecorder, StatusRecorder<org.apache.flink.kubernetes.operator.api.FlinkDeployment,org.apache.flink.kubernetes.operator.api.status.FlinkDeploymentStatus> statusRecorder)

Uses of StatusRecorder in org.apache.flink.kubernetes.operator.reconciler.sessionjob

Constructors in org.apache.flink.kubernetes.operator.reconciler.sessionjob with parameters of type StatusRecorder

Constructor	Description
SessionJobReconciler(EventRecorder eventRecorder, StatusRecorder<org.apache.flink.kubernetes.operator.api.FlinkSessionJob,org.apache.flink.kubernetes.operator.api.status.FlinkSessionJobStatus> statusRecorder)

Uses of StatusRecorder in org.apache.flink.kubernetes.operator.utils

Methods in org.apache.flink.kubernetes.operator.utils that return StatusRecorder

Modifier and Type	Method	Description
static <S extends org.apache.flink.kubernetes.operator.api.status.CommonStatus<?>,CR extends org.apache.flink.kubernetes.operator.api.AbstractFlinkResource<?,S>> StatusRecorder<CR,S>	StatusRecorder.create(io.fabric8.kubernetes.client.KubernetesClient kubernetesClient, MetricManager<CR> metricManager, java.util.Collection<org.apache.flink.kubernetes.operator.api.listener.FlinkResourceListener> listeners)