Uses of Interface
org.apache.flink.kubernetes.operator.observer.Observer
-
-
Uses of Observer in org.apache.flink.kubernetes.operator.controller
Constructors in org.apache.flink.kubernetes.operator.controller with parameters of type Observer Constructor Description FlinkSessionJobController(FlinkConfigManager configManager, java.util.Set<FlinkResourceValidator> validators, Reconciler<FlinkSessionJob> reconciler, Observer<FlinkSessionJob> observer, StatusRecorder<FlinkSessionJob,FlinkSessionJobStatus> statusRecorder, EventRecorder eventRecorder)
-
Uses of Observer in org.apache.flink.kubernetes.operator.observer
Classes in org.apache.flink.kubernetes.operator.observer that implement Observer Modifier and Type Class Description class
AbstractFlinkResourceObserver<CR extends AbstractFlinkResource<?,?>,CTX extends ObserverContext>
Base observer for all Flink resources. -
Uses of Observer in org.apache.flink.kubernetes.operator.observer.deployment
Classes in org.apache.flink.kubernetes.operator.observer.deployment that implement Observer Modifier and Type Class Description class
AbstractFlinkDeploymentObserver
Base observer for session and application clusters.class
ApplicationObserver
The observer ofMode.APPLICATION
cluster.class
SessionObserver
The observer of theMode.SESSION
cluster.Methods in org.apache.flink.kubernetes.operator.observer.deployment that return Observer Modifier and Type Method Description Observer<FlinkDeployment>
FlinkDeploymentObserverFactory. getOrCreate(FlinkDeployment flinkApp)
-
Uses of Observer in org.apache.flink.kubernetes.operator.observer.sessionjob
Classes in org.apache.flink.kubernetes.operator.observer.sessionjob that implement Observer Modifier and Type Class Description class
FlinkSessionJobObserver
The observer ofFlinkSessionJob
.
-