Uses of Interface
org.apache.flink.kubernetes.operator.reconciler.Reconciler
-
-
Uses of Reconciler in org.apache.flink.kubernetes.operator.controller
Constructors in org.apache.flink.kubernetes.operator.controller with parameters of type Reconciler Constructor Description FlinkSessionJobController(FlinkConfigManager configManager, java.util.Set<FlinkResourceValidator> validators, Reconciler<FlinkSessionJob> reconciler, Observer<FlinkSessionJob> observer, StatusRecorder<FlinkSessionJob,FlinkSessionJobStatus> statusRecorder, EventRecorder eventRecorder)
-
Uses of Reconciler in org.apache.flink.kubernetes.operator.reconciler.deployment
Classes in org.apache.flink.kubernetes.operator.reconciler.deployment that implement Reconciler Modifier and Type Class Description class
AbstractFlinkResourceReconciler<CR extends AbstractFlinkResource<SPEC,STATUS>,SPEC extends AbstractFlinkSpec,STATUS extends CommonStatus<SPEC>>
Base class for all Flink resource reconcilers.class
AbstractJobReconciler<CR extends AbstractFlinkResource<SPEC,STATUS>,SPEC extends AbstractFlinkSpec,STATUS extends CommonStatus<SPEC>>
Reconciler responsible for handling the job lifecycle according to the desired and current states.class
ApplicationReconciler
Reconciler Flink Application deployments.class
SessionReconciler
Reconciler responsible for handling the session cluster lifecycle according to the desired and current states.Methods in org.apache.flink.kubernetes.operator.reconciler.deployment that return Reconciler Modifier and Type Method Description Reconciler<FlinkDeployment>
ReconcilerFactory. getOrCreate(FlinkDeployment flinkApp)
-
Uses of Reconciler in org.apache.flink.kubernetes.operator.reconciler.sessionjob
Classes in org.apache.flink.kubernetes.operator.reconciler.sessionjob that implement Reconciler Modifier and Type Class Description class
SessionJobReconciler
The reconciler for theFlinkSessionJob
.
-