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

Packages that use EventRecorder

Package	Description
org.apache.flink.kubernetes.operator.autoscaler
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.service
org.apache.flink.kubernetes.operator.utils

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

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

Modifier and Type	Method	Description
static org.apache.flink.autoscaler.JobAutoScaler<io.javaoperatorsdk.operator.processing.event.ResourceID,KubernetesJobAutoScalerContext>	AutoscalerFactory.create(io.fabric8.kubernetes.client.KubernetesClient client, EventRecorder eventRecorder)

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

Constructor	Description
KubernetesAutoScalerEventHandler(EventRecorder eventRecorder)

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(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 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(EventRecorder eventRecorder)
JobStatusObserver(EventRecorder eventRecorder)
SnapshotObserver(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(EventRecorder eventRecorder)
ApplicationObserver(EventRecorder eventRecorder)
FlinkDeploymentObserverFactory(EventRecorder eventRecorder)
SessionObserver(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(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(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 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(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.service

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

Constructor	Description
FlinkResourceContextFactory(FlinkConfigManager configManager, KubernetesOperatorMetricGroup operatorMetricGroup, EventRecorder eventRecorder)
NativeFlinkService(io.fabric8.kubernetes.client.KubernetesClient kubernetesClient, ArtifactManager artifactManager, java.util.concurrent.ExecutorService executorService, FlinkOperatorConfiguration operatorConfig, EventRecorder eventRecorder)

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	SnapshotUtils.resetSnapshotTriggers(org.apache.flink.kubernetes.operator.api.AbstractFlinkResource<?,?> resource, EventRecorder eventRecorder, io.fabric8.kubernetes.client.KubernetesClient client)
static boolean	ValidatorUtils.validateSupportedVersion(FlinkResourceContext<?> ctx, EventRecorder eventRecorder)