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

Class ReconcilerFactory

  • public class ReconcilerFactory
extends java.lang.Object
    The factory to create reconciler based on app mode.

    • Constructor Summary

      Constructors 
      Constructor Description
      ReconcilerFactory​(io.fabric8.kubernetes.client.KubernetesClient kubernetesClient, FlinkServiceFactory flinkServiceFactory, FlinkConfigManager configManager, EventRecorder eventRecorder, StatusRecorder<org.apache.flink.kubernetes.operator.api.FlinkDeployment,​org.apache.flink.kubernetes.operator.api.status.FlinkDeploymentStatus> deploymentStatusRecorder)  

    • Method Summary

      All Methods Instance Methods Concrete Methods 
      Modifier and Type Method Description
      Reconciler<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

      • ReconcilerFactory

        public ReconcilerFactory​(io.fabric8.kubernetes.client.KubernetesClient kubernetesClient,
                         FlinkServiceFactory flinkServiceFactory,
                         FlinkConfigManager configManager,
                         EventRecorder eventRecorder,
                         StatusRecorder<org.apache.flink.kubernetes.operator.api.FlinkDeployment,​org.apache.flink.kubernetes.operator.api.status.FlinkDeploymentStatus> deploymentStatusRecorder)

    • Method Detail

      • getOrCreate

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