Interface JobAutoScaler

    • Method Detail

      • scale

        void scale​(FlinkResourceContext<?> ctx)
            throws java.lang.Exception
        Called as part of the reconciliation loop. Returns true if this call led to scaling.
        Throws:
        java.lang.Exception
      • cleanup

        void cleanup​(FlinkResourceContext<?> ctx)
        Called when the custom resource is deleted.