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<FlinkDeployment,FlinkDeploymentStatus> statusRecorder, EventRecorder eventRecorder, CanaryResourceManager<FlinkDeployment> canaryResourceManager)
FlinkSessionJobController(java.util.Set<FlinkResourceValidator> validators, FlinkResourceContextFactory ctxFactory, Reconciler<FlinkSessionJob> reconciler, Observer<FlinkSessionJob> observer, StatusRecorder<FlinkSessionJob,FlinkSessionJobStatus> statusRecorder, EventRecorder eventRecorder, CanaryResourceManager<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 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.

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, JobAutoScaler<io.javaoperatorsdk.operator.processing.event.ResourceID,KubernetesJobAutoScalerContext> autoscaler)
AbstractJobReconciler(EventRecorder eventRecorder, StatusRecorder<CR,STATUS> statusRecorder, JobAutoScaler<io.javaoperatorsdk.operator.processing.event.ResourceID,KubernetesJobAutoScalerContext> autoscaler)
ApplicationReconciler(EventRecorder eventRecorder, StatusRecorder<FlinkDeployment,FlinkDeploymentStatus> statusRecorder, JobAutoScaler<io.javaoperatorsdk.operator.processing.event.ResourceID,KubernetesJobAutoScalerContext> autoscaler)
ReconcilerFactory(EventRecorder eventRecorder, StatusRecorder<FlinkDeployment,FlinkDeploymentStatus> deploymentStatusRecorder, JobAutoScaler<io.javaoperatorsdk.operator.processing.event.ResourceID,KubernetesJobAutoScalerContext> autoscaler)
SessionReconciler(EventRecorder eventRecorder, StatusRecorder<FlinkDeployment,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<FlinkSessionJob,FlinkSessionJobStatus> statusRecorder, JobAutoScaler<io.javaoperatorsdk.operator.processing.event.ResourceID,KubernetesJobAutoScalerContext> autoscaler)

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 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 StatusRecorder<FlinkStateSnapshot,FlinkStateSnapshotStatus>	StatusRecorder.createForFlinkStateSnapshot(io.fabric8.kubernetes.client.KubernetesClient kubernetesClient, MetricManager<FlinkStateSnapshot> metricManager, java.util.Collection<FlinkResourceListener> listeners)