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(EventRecorder eventRecorder, StatusRecorder<FlinkDeployment,FlinkDeploymentStatus> deploymentStatusRecorder, JobAutoScaler<io.javaoperatorsdk.operator.processing.event.ResourceID,KubernetesJobAutoScalerContext> autoscaler)

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(EventRecorder eventRecorder,
                         StatusRecorder<FlinkDeployment,FlinkDeploymentStatus> deploymentStatusRecorder,
                         JobAutoScaler<io.javaoperatorsdk.operator.processing.event.ResourceID,KubernetesJobAutoScalerContext> autoscaler)

Method Detail

getOrCreate

public Reconciler<FlinkDeployment> getOrCreate(FlinkDeployment flinkApp)