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

Interface Supervisor

All Known Subinterfaces:
StreamSupervisor
public interface Supervisor
An interface representing a general supervisor for managing ingestion tasks. For streaming ingestion use cases, see StreamSupervisor.

  • Method Details

    • start

      void start()

    • stop

      void stop(boolean stopGracefully)
      Parameters:
      stopGracefully - If true, supervisor will cleanly shutdown managed tasks if possible (for example signalling them to publish their segments and exit). The implementation may block until the tasks have either acknowledged or completed. If false, supervisor will stop immediately and leave any running tasks as they are.

    • stopAsync

      default com.google.common.util.concurrent.ListenableFuture<Void> stopAsync()
      Starts non-graceful shutdown of the supervisor and returns a future that completes when shutdown is complete.

    • getStatus

      SupervisorReport getStatus()

    • getState

      SupervisorStateManager.State getState()

    • getStats

      default Map<String,Map<String,Object>> getStats()
      Returns all stats from stream consumer. If includeOnlyStreamConsumerStats is true, returns only stream platform stats, like Kafka metrics.

    • getParseErrors

      default List<ParseExceptionReport> getParseErrors()

    • isHealthy

      @Nullable default Boolean isHealthy()

    • createAutoscaler

      default SupervisorTaskAutoScaler createAutoscaler(SupervisorSpec spec)

    • reset

      void reset(@Nullable DataSourceMetadata dataSourceMetadata)
      Resets any stored metadata by the supervisor.
      Parameters:
      dataSourceMetadata - optional dataSource metadata.