Uses of Class
org.apache.flink.kubernetes.operator.utils.EventRecorder
-
-
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 JobAutoScaler
JobAutoscalerFactoryImpl. create(io.fabric8.kubernetes.client.KubernetesClient kubernetesClient, EventRecorder eventRecorder)
Constructors in org.apache.flink.kubernetes.operator.autoscaler with parameters of type EventRecorder Constructor Description JobVertexScaler(EventRecorder eventRecorder)
ScalingExecutor(io.fabric8.kubernetes.client.KubernetesClient kubernetesClient, JobVertexScaler jobVertexScaler, EventRecorder eventRecorder)
ScalingExecutor(io.fabric8.kubernetes.client.KubernetesClient kubernetesClient, 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(FlinkConfigManager configManager, java.util.Set<FlinkResourceValidator> validators, FlinkResourceContextFactory ctxFactory, ReconcilerFactory reconcilerFactory, FlinkDeploymentObserverFactory observerFactory, StatusRecorder<FlinkDeployment,FlinkDeploymentStatus> statusRecorder, EventRecorder eventRecorder)
FlinkSessionJobController(FlinkConfigManager configManager, java.util.Set<FlinkResourceValidator> validators, FlinkResourceContextFactory ctxFactory, 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(FlinkConfigManager configManager, EventRecorder eventRecorder)
SavepointObserver(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(FlinkConfigManager configManager, EventRecorder eventRecorder)
ApplicationObserver(FlinkConfigManager configManager, EventRecorder eventRecorder)
FlinkDeploymentObserverFactory(FlinkConfigManager configManager, EventRecorder eventRecorder)
SessionObserver(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(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
Methods in org.apache.flink.kubernetes.operator.reconciler.deployment with parameters of type EventRecorder Modifier and Type Method Description JobAutoScaler
JobAutoScalerFactory. create(io.fabric8.kubernetes.client.KubernetesClient kubernetesClient, EventRecorder eventRecorder)
JobAutoScaler
NoopJobAutoscalerFactory. create(io.fabric8.kubernetes.client.KubernetesClient kubernetesClient, EventRecorder eventRecorder)
Constructors in org.apache.flink.kubernetes.operator.reconciler.deployment with parameters of type EventRecorder Constructor Description AbstractFlinkResourceReconciler(io.fabric8.kubernetes.client.KubernetesClient kubernetesClient, EventRecorder eventRecorder, StatusRecorder<CR,STATUS> statusRecorder, JobAutoScalerFactory autoscalerFactory)
AbstractJobReconciler(io.fabric8.kubernetes.client.KubernetesClient kubernetesClient, EventRecorder eventRecorder, StatusRecorder<CR,STATUS> statusRecorder, JobAutoScalerFactory autoscalerFactory)
ApplicationReconciler(io.fabric8.kubernetes.client.KubernetesClient kubernetesClient, EventRecorder eventRecorder, StatusRecorder<FlinkDeployment,FlinkDeploymentStatus> statusRecorder, JobAutoScalerFactory autoscalerFactory)
ReconcilerFactory(io.fabric8.kubernetes.client.KubernetesClient kubernetesClient, FlinkConfigManager configManager, EventRecorder eventRecorder, StatusRecorder<FlinkDeployment,FlinkDeploymentStatus> deploymentStatusRecorder, JobAutoScalerFactory autoscalerFactory)
SessionReconciler(io.fabric8.kubernetes.client.KubernetesClient kubernetesClient, EventRecorder eventRecorder, StatusRecorder<FlinkDeployment,FlinkDeploymentStatus> statusRecorder, FlinkConfigManager configManager)
-
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, 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)
-