Class FlinkDeploymentController

  • All Implemented Interfaces:
    io.javaoperatorsdk.operator.api.reconciler.Cleaner<FlinkDeployment>, io.javaoperatorsdk.operator.api.reconciler.ErrorStatusHandler<FlinkDeployment>, io.javaoperatorsdk.operator.api.reconciler.EventSourceInitializer<FlinkDeployment>, io.javaoperatorsdk.operator.api.reconciler.Reconciler<FlinkDeployment>

    public class FlinkDeploymentController
    extends java.lang.Object
    implements io.javaoperatorsdk.operator.api.reconciler.Reconciler<FlinkDeployment>, io.javaoperatorsdk.operator.api.reconciler.ErrorStatusHandler<FlinkDeployment>, io.javaoperatorsdk.operator.api.reconciler.EventSourceInitializer<FlinkDeployment>, io.javaoperatorsdk.operator.api.reconciler.Cleaner<FlinkDeployment>
    Controller that runs the main reconcile loop for Flink deployments.
    • Method Detail

      • cleanup

        public io.javaoperatorsdk.operator.api.reconciler.DeleteControl cleanup​(FlinkDeployment flinkApp,
                                                                                io.javaoperatorsdk.operator.api.reconciler.Context josdkContext)
        Specified by:
        cleanup in interface io.javaoperatorsdk.operator.api.reconciler.Cleaner<FlinkDeployment>
      • reconcile

        public io.javaoperatorsdk.operator.api.reconciler.UpdateControl<FlinkDeployment> reconcile​(FlinkDeployment flinkApp,
                                                                                                   io.javaoperatorsdk.operator.api.reconciler.Context josdkContext)
                                                                                            throws java.lang.Exception
        Specified by:
        reconcile in interface io.javaoperatorsdk.operator.api.reconciler.Reconciler<FlinkDeployment>
        Throws:
        java.lang.Exception
      • prepareEventSources

        public java.util.Map<java.lang.String,​io.javaoperatorsdk.operator.processing.event.source.EventSource> prepareEventSources​(io.javaoperatorsdk.operator.api.reconciler.EventSourceContext<FlinkDeployment> context)
        Specified by:
        prepareEventSources in interface io.javaoperatorsdk.operator.api.reconciler.EventSourceInitializer<FlinkDeployment>
      • updateErrorStatus

        public io.javaoperatorsdk.operator.api.reconciler.ErrorStatusUpdateControl<FlinkDeployment> updateErrorStatus​(FlinkDeployment flinkDeployment,
                                                                                                                      io.javaoperatorsdk.operator.api.reconciler.Context<FlinkDeployment> context,
                                                                                                                      java.lang.Exception e)
        Specified by:
        updateErrorStatus in interface io.javaoperatorsdk.operator.api.reconciler.ErrorStatusHandler<FlinkDeployment>