Class StaleRecoveringContainerScrubbingService

java.lang.Object
org.apache.hadoop.hdds.utils.BackgroundService
org.apache.hadoop.ozone.container.keyvalue.statemachine.background.StaleRecoveringContainerScrubbingService

public class StaleRecoveringContainerScrubbingService extends org.apache.hadoop.hdds.utils.BackgroundService
A per-datanode container stale recovering container scrubbing service takes in charge of deleting stale recovering containers.
  • Nested Class Summary

    Nested classes/interfaces inherited from class org.apache.hadoop.hdds.utils.BackgroundService

    org.apache.hadoop.hdds.utils.BackgroundService.PeriodicalTask
  • Constructor Summary

    Constructors
    Constructor
    Description
    StaleRecoveringContainerScrubbingService(long interval, TimeUnit unit, int threadPoolSize, long serviceTimeout, ContainerSet containerSet)
     
  • Method Summary

    Modifier and Type
    Method
    Description
    org.apache.hadoop.hdds.utils.BackgroundTaskQueue
     

    Methods inherited from class org.apache.hadoop.hdds.utils.BackgroundService

    execTaskCompletion, getExecutorService, getFuture, getIntervalMillis, getThreadCount, runPeriodicalTaskNow, setInterval, setPoolSize, setServiceTimeoutInNanos, shutdown, start

    Methods inherited from class java.lang.Object

    clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
  • Constructor Details

    • StaleRecoveringContainerScrubbingService

      public StaleRecoveringContainerScrubbingService(long interval, TimeUnit unit, int threadPoolSize, long serviceTimeout, ContainerSet containerSet)
  • Method Details

    • getTasks

      public org.apache.hadoop.hdds.utils.BackgroundTaskQueue getTasks()
      Specified by:
      getTasks in class org.apache.hadoop.hdds.utils.BackgroundService