Package org.apache.flink.kubernetes.operator.observer
-
Interface Summary Interface Description Observer<CR> The Observer of custom resource.ObserverContext Context for the currently observed resource. -
Class Summary Class Description AbstractFlinkResourceObserver<CR extends org.apache.flink.kubernetes.operator.api.AbstractFlinkResource<?,?>,CTX extends ObserverContext> Base observer for all Flink resources.ClusterHealthEvaluator Evaluates whether the cluster is healthy.ClusterHealthObserver An observer to observe the cluster health.JobStatusObserver<R extends org.apache.flink.kubernetes.operator.api.AbstractFlinkResource<?,?>,CTX extends ObserverContext> An observer to observe the job status.SavepointFetchResult Result of a fetch savepoint operation.SavepointObserver<CR extends org.apache.flink.kubernetes.operator.api.AbstractFlinkResource<?,STATUS>,STATUS extends org.apache.flink.kubernetes.operator.api.status.CommonStatus<?>> An observer of savepoint progress.