Uses of Interface
org.apache.flink.kubernetes.operator.observer.Observer

Packages that use Observer

Package	Description
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

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<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)

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 org.apache.flink.kubernetes.operator.api.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 of Mode.APPLICATION cluster.
class	SessionObserver	The observer of the Mode.SESSION cluster.

Methods in org.apache.flink.kubernetes.operator.observer.deployment that return Observer

Modifier and Type	Method	Description
Observer<org.apache.flink.kubernetes.operator.api.FlinkDeployment>	FlinkDeploymentObserverFactory.getOrCreate(org.apache.flink.kubernetes.operator.api.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 of FlinkSessionJob.