Uses of Class
org.apache.flink.kubernetes.operator.utils.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(FlinkConfigManager configManager, java.util.Set<FlinkResourceValidator> validators, ReconcilerFactory reconcilerFactory, FlinkDeploymentObserverFactory observerFactory, StatusRecorder<FlinkDeployment,FlinkDeploymentStatus> statusRecorder, EventRecorder eventRecorder)
FlinkSessionJobController(FlinkConfigManager configManager, java.util.Set<FlinkResourceValidator> validators, Reconciler<FlinkSessionJob> reconciler, Observer<FlinkSessionJob> observer, StatusRecorder<FlinkSessionJob,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<FlinkDeployment,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<FlinkDeployment,FlinkDeploymentStatus> statusRecorder)
ReconcilerFactory(io.fabric8.kubernetes.client.KubernetesClient kubernetesClient, FlinkServiceFactory flinkServiceFactory, FlinkConfigManager configManager, EventRecorder eventRecorder, StatusRecorder<FlinkDeployment,FlinkDeploymentStatus> deploymentStatusRecorder)
SessionReconciler(io.fabric8.kubernetes.client.KubernetesClient kubernetesClient, FlinkService flinkService, FlinkConfigManager configManager, EventRecorder eventRecorder, StatusRecorder<FlinkDeployment,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<FlinkSessionJob,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<FlinkResourceListener> listeners)
Methods in org.apache.flink.kubernetes.operator.utils with parameters of type EventRecorder Modifier and Type Method Description static void
SavepointUtils. resetTriggerIfJobNotRunning(AbstractFlinkResource<?,?> resource, EventRecorder eventRecorder)
-