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

Packages that use EventRecorder

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

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

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

Constructor	Description
FlinkDeploymentController(FlinkConfigManager configManager, java.util.Set<FlinkResourceValidator> validators, ReconcilerFactory reconcilerFactory, FlinkDeploymentObserverFactory observerFactory, StatusRecorder<org.apache.flink.kubernetes.operator.api.FlinkDeployment,org.apache.flink.kubernetes.operator.api.status.FlinkDeploymentStatus> statusRecorder, EventRecorder eventRecorder)
FlinkSessionJobController(FlinkConfigManager configManager, java.util.Set<FlinkResourceValidator> validators, 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)

Uses of EventRecorder in org.apache.flink.kubernetes.operator.observer

Fields in org.apache.flink.kubernetes.operator.observer declared as EventRecorder

Modifier and Type	Field	Description
protected EventRecorder	AbstractFlinkResourceObserver.eventRecorder
protected EventRecorder	JobStatusObserver.eventRecorder

Constructors in org.apache.flink.kubernetes.operator.observer with parameters of type EventRecorder

Constructor	Description
AbstractFlinkResourceObserver(FlinkConfigManager configManager, EventRecorder eventRecorder)
JobStatusObserver(FlinkService flinkService, FlinkConfigManager configManager, EventRecorder eventRecorder)
SavepointObserver(FlinkService flinkService, FlinkConfigManager configManager, EventRecorder eventRecorder)

Uses of EventRecorder in org.apache.flink.kubernetes.operator.observer.deployment

Constructors in org.apache.flink.kubernetes.operator.observer.deployment with parameters of type EventRecorder

Constructor	Description
AbstractFlinkDeploymentObserver(FlinkService flinkService, FlinkConfigManager configManager, EventRecorder eventRecorder)
ApplicationObserver(FlinkService flinkService, FlinkConfigManager configManager, EventRecorder eventRecorder)
FlinkDeploymentObserverFactory(FlinkServiceFactory flinkServiceFactory, FlinkConfigManager configManager, StatusRecorder<org.apache.flink.kubernetes.operator.api.FlinkDeployment,org.apache.flink.kubernetes.operator.api.status.FlinkDeploymentStatus> statusRecorder, EventRecorder eventRecorder)
SessionObserver(FlinkService flinkService, FlinkConfigManager configManager, EventRecorder eventRecorder)

Uses of EventRecorder in org.apache.flink.kubernetes.operator.observer.sessionjob

Constructors in org.apache.flink.kubernetes.operator.observer.sessionjob with parameters of type EventRecorder

Constructor	Description
FlinkSessionJobObserver(FlinkServiceFactory flinkServiceFactory, FlinkConfigManager configManager, EventRecorder eventRecorder)

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

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

Modifier and Type	Field	Description
protected EventRecorder	AbstractFlinkResourceReconciler.eventRecorder

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

Constructor	Description
AbstractFlinkResourceReconciler(io.fabric8.kubernetes.client.KubernetesClient kubernetesClient, FlinkConfigManager configManager, EventRecorder eventRecorder, StatusRecorder<CR,STATUS> statusRecorder)
AbstractJobReconciler(io.fabric8.kubernetes.client.KubernetesClient kubernetesClient, FlinkConfigManager configManager, EventRecorder eventRecorder, StatusRecorder<CR,STATUS> statusRecorder)
ApplicationReconciler(io.fabric8.kubernetes.client.KubernetesClient kubernetesClient, FlinkService flinkService, FlinkConfigManager configManager, EventRecorder eventRecorder, StatusRecorder<org.apache.flink.kubernetes.operator.api.FlinkDeployment,org.apache.flink.kubernetes.operator.api.status.FlinkDeploymentStatus> statusRecorder)
ReconcilerFactory(io.fabric8.kubernetes.client.KubernetesClient kubernetesClient, FlinkServiceFactory flinkServiceFactory, FlinkConfigManager configManager, EventRecorder eventRecorder, StatusRecorder<org.apache.flink.kubernetes.operator.api.FlinkDeployment,org.apache.flink.kubernetes.operator.api.status.FlinkDeploymentStatus> deploymentStatusRecorder)
SessionReconciler(io.fabric8.kubernetes.client.KubernetesClient kubernetesClient, FlinkService flinkService, FlinkConfigManager configManager, EventRecorder eventRecorder, StatusRecorder<org.apache.flink.kubernetes.operator.api.FlinkDeployment,org.apache.flink.kubernetes.operator.api.status.FlinkDeploymentStatus> statusRecorder)

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

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

Constructor	Description
SessionJobReconciler(io.fabric8.kubernetes.client.KubernetesClient kubernetesClient, FlinkServiceFactory flinkServiceFactory, FlinkConfigManager configManager, EventRecorder eventRecorder, StatusRecorder<org.apache.flink.kubernetes.operator.api.FlinkSessionJob,org.apache.flink.kubernetes.operator.api.status.FlinkSessionJobStatus> statusRecorder)

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

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

Modifier and Type	Method	Description
static EventRecorder	EventRecorder.create(io.fabric8.kubernetes.client.KubernetesClient client, java.util.Collection<org.apache.flink.kubernetes.operator.api.listener.FlinkResourceListener> listeners)

Methods in org.apache.flink.kubernetes.operator.utils with parameters of type EventRecorder

Modifier and Type	Method	Description
static void	SavepointUtils.resetTriggerIfJobNotRunning(org.apache.flink.kubernetes.operator.api.AbstractFlinkResource<?,?> resource, EventRecorder eventRecorder)