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 static JobAutoScaler<io.javaoperatorsdk.operator.processing.event.ResourceID,KubernetesJobAutoScalerContext>
AutoscalerFactory. create(io.fabric8.kubernetes.client.KubernetesClient client, EventRecorder eventRecorder, ClusterResourceManager clusterResourceManager)
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<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 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
-
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<FlinkSessionJob,FlinkSessionJobStatus> statusRecorder, JobAutoScaler<io.javaoperatorsdk.operator.processing.event.ResourceID,KubernetesJobAutoScalerContext> autoscaler)
-
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<FlinkResourceListener> listeners)
Methods in org.apache.flink.kubernetes.operator.utils with parameters of type EventRecorder Modifier and Type Method Description static void
SnapshotUtils. resetSnapshotTriggers(AbstractFlinkResource<?,?> resource, EventRecorder eventRecorder, io.fabric8.kubernetes.client.KubernetesClient client)
static boolean
ValidatorUtils. validateSupportedVersion(FlinkResourceContext<?> ctx, EventRecorder eventRecorder)
-