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

Class ReconcilerFactory

java.lang.Object

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

public class ReconcilerFactory
extends java.lang.Object

The factory to create reconciler based on app mode.

Constructor Summary

Constructors

Constructor	Description
ReconcilerFactory(FlinkConfigManager configManager, EventRecorder eventRecorder, StatusRecorder<FlinkDeployment,FlinkDeploymentStatus> deploymentStatusRecorder, JobAutoScalerFactory autoscalerFactory)

Method Summary

Modifier and Type	Method	Description
Reconciler<FlinkDeployment>	getOrCreate(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(FlinkConfigManager configManager,
                         EventRecorder eventRecorder,
                         StatusRecorder<FlinkDeployment,FlinkDeploymentStatus> deploymentStatusRecorder,
                         JobAutoScalerFactory autoscalerFactory)

Method Detail

getOrCreate

public Reconciler<FlinkDeployment> getOrCreate(FlinkDeployment flinkApp)