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(FlinkServiceFactory flinkServiceFactory, FlinkConfigManager configManager, StatusRecorder<org.apache.flink.kubernetes.operator.api.FlinkDeployment,org.apache.flink.kubernetes.operator.api.status.FlinkDeploymentStatus> statusRecorder, EventRecorder eventRecorder)

Method Summary

Modifier and Type	Method	Description
Observer<org.apache.flink.kubernetes.operator.api.FlinkDeployment>	getOrCreate(org.apache.flink.kubernetes.operator.api.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(FlinkServiceFactory flinkServiceFactory,
                                      FlinkConfigManager configManager,
                                      StatusRecorder<org.apache.flink.kubernetes.operator.api.FlinkDeployment,org.apache.flink.kubernetes.operator.api.status.FlinkDeploymentStatus> statusRecorder,
                                      EventRecorder eventRecorder)

Method Detail

getOrCreate

public Observer<org.apache.flink.kubernetes.operator.api.FlinkDeployment> getOrCreate(org.apache.flink.kubernetes.operator.api.FlinkDeployment flinkApp)