SessionObserver (Flink Kubernetes: 1.4-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.SessionObserver

All Implemented Interfaces:

Observer<FlinkDeployment>
```
public class SessionObserver
extends AbstractFlinkDeploymentObserver
```
The observer of the Mode.SESSION 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
  configManager, eventRecorder

Constructor Summary

Constructors
Constructor Description

SessionObserver(FlinkConfigManager configManager, EventRecorder eventRecorder)

Method Summary

All Methods Instance Methods Concrete Methods
Modifier and Type	Method	Description
`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
clearErrorsIfDeploymentIsHealthy, isJmDeploymentReady, isSuspendedJob, observeInternal, observeJmDeployment, updateStatusToDeployedIfAlreadyUpgraded

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
  - SessionObserver
```
public SessionObserver(FlinkConfigManager configManager,
                       EventRecorder eventRecorder)
```
- Method Detail
  - observeFlinkCluster
```
public 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