ApplicationObserver (Flink Kubernetes: 1.8-SNAPSHOT API)

java.lang.Object
- org.apache.flink.kubernetes.operator.observer.AbstractFlinkResourceObserver<FlinkDeployment>
- - org.apache.flink.kubernetes.operator.observer.deployment.AbstractFlinkDeploymentObserver
  - - org.apache.flink.kubernetes.operator.observer.deployment.ApplicationObserver

All Implemented Interfaces:

Observer<FlinkDeployment>
```
public class ApplicationObserver
extends AbstractFlinkDeploymentObserver
```
The observer of Mode.APPLICATION cluster.

Field Summary
- Fields inherited from class org.apache.flink.kubernetes.operator.observer.deployment.AbstractFlinkDeploymentObserver
  logger
- Fields inherited from class org.apache.flink.kubernetes.operator.observer.AbstractFlinkResourceObserver
  eventRecorder

Constructor Summary

Constructors
Constructor Description

ApplicationObserver(EventRecorder eventRecorder)

Method Summary

All Methods Instance Methods Concrete Methods
Modifier and Type	Method	Description
`protected void`	`observeFlinkCluster(FlinkResourceContext<FlinkDeployment> ctx)`	Observe the flinkApp status when the cluster is ready.

Methods inherited from class org.apache.flink.kubernetes.operator.observer.deployment.AbstractFlinkDeploymentObserver
checkIfAlreadyUpgraded, clearErrorsIfDeploymentIsHealthy, isJmDeploymentReady, isSuspendedJob, observeInternal, observeJmDeployment

Methods inherited from class org.apache.flink.kubernetes.operator.observer.AbstractFlinkResourceObserver
isResourceReadyToBeObserved, observe

Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

- Constructor Detail
  - ApplicationObserver
```
public ApplicationObserver(EventRecorder eventRecorder)
```
- Method Detail
  - observeFlinkCluster
```
protected void observeFlinkCluster(FlinkResourceContext<FlinkDeployment> ctx)
```
    Description copied from class: AbstractFlinkDeploymentObserver
    
    Observe the flinkApp status when the cluster is ready. It will be implemented by child class to reflect the changed status on the flinkApp resource.
    
    Specified by:
    
    observeFlinkCluster in class AbstractFlinkDeploymentObserver
    
    Parameters:
    
    ctx - the context with which the operation is executed