Interface Reconciler<CR extends AbstractFlinkResource<?,​?>>

    • Method Detail

      • reconcile

        void reconcile​(FlinkResourceContext<CR> context)
                throws java.lang.Exception
        This is called when receiving the create or update event of the custom resource.
        Parameters:
        context - the context with which the operation is executed
        Throws:
        java.lang.Exception - Error during reconciliation.
      • cleanup

        io.javaoperatorsdk.operator.api.reconciler.DeleteControl cleanup​(FlinkResourceContext<CR> context)
        This is called when receiving the delete event of custom resource. This method is meant to cleanup the associated components like the Flink job components.
        Parameters:
        context - the context with which the operation is executed
        Returns:
        DeleteControl to manage the deletion behavior