Package org.apache.druid.indexing.overlord.supervisor.autoscaler

Interface SupervisorTaskAutoScaler

public interface SupervisorTaskAutoScaler

  • Method Summary

    Modifier and Type
    Method
    Description
    default int
    computeTaskCountForRollover()
    Computes the optimal task count during task rollover, allowing a non-disruptive scale-down.
    void
    reset()
     
    void
    start()
     
    void
    stop()
     

  • Method Details

    • start

      void start()

    • stop

      void stop()

    • reset

      void reset()

    • computeTaskCountForRollover

      default int computeTaskCountForRollover()
      Computes the optimal task count during task rollover, allowing a non-disruptive scale-down. Must be called by the supervisor when tasks are ending their duration.
      Returns:
      optimal task count for scale-down, or -1 if no change needed