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​(EventRecorder eventRecorder, StatusRecorder<org.apache.flink.kubernetes.operator.api.FlinkDeployment,​org.apache.flink.kubernetes.operator.api.status.FlinkDeploymentStatus> deploymentStatusRecorder, org.apache.flink.autoscaler.JobAutoScaler<io.javaoperatorsdk.operator.processing.event.ResourceID,​KubernetesJobAutoScalerContext> autoscaler)  

    • 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​(EventRecorder eventRecorder,
                         StatusRecorder<org.apache.flink.kubernetes.operator.api.FlinkDeployment,​org.apache.flink.kubernetes.operator.api.status.FlinkDeploymentStatus> deploymentStatusRecorder,
                         org.apache.flink.autoscaler.JobAutoScaler<io.javaoperatorsdk.operator.processing.event.ResourceID,​KubernetesJobAutoScalerContext> autoscaler)

    • Method Detail

      • getOrCreate

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