Class FlinkDeploymentObserverFactory


  • public class FlinkDeploymentObserverFactory
    extends java.lang.Object
    The factory to create the observer based on the FlinkDeployment mode.