Package org.apache.flink.kubernetes.operator.observer.deployment

Class FlinkDeploymentObserverFactory

java.lang.Object

org.apache.flink.kubernetes.operator.observer.deployment.FlinkDeploymentObserverFactory

public class FlinkDeploymentObserverFactory
extends java.lang.Object

The factory to create the observer based on the FlinkDeployment mode.

Constructor Summary

Constructors

Constructor	Description
FlinkDeploymentObserverFactory(EventRecorder eventRecorder)

Method Summary

Modifier and Type	Method	Description
Observer<FlinkDeployment>	getOrCreate(FlinkDeployment flinkApp)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

FlinkDeploymentObserverFactory

public FlinkDeploymentObserverFactory(EventRecorder eventRecorder)

Method Detail

getOrCreate

public Observer<FlinkDeployment> getOrCreate(FlinkDeployment flinkApp)