Package org.apache.hadoop.ozone.om.service

Class SnapshotDiffCleanupService

java.lang.Object
org.apache.hadoop.hdds.utils.BackgroundService
org.apache.hadoop.ozone.om.service.SnapshotDiffCleanupService
public class SnapshotDiffCleanupService extends org.apache.hadoop.hdds.utils.BackgroundService
Background service to clean-up snapDiff jobs which are stable and corresponding reports.

  • Nested Class Summary

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

    org.apache.hadoop.hdds.utils.BackgroundService.PeriodicalTask

  • Field Summary

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

    LOG

  • Constructor Summary

    Constructors
    Constructor
    Description
    SnapshotDiffCleanupService(long interval, long serviceTimeout, OzoneManager ozoneManager, org.apache.hadoop.hdds.utils.db.managed.ManagedRocksDB db, org.rocksdb.ColumnFamilyHandle snapDiffJobCfh, org.rocksdb.ColumnFamilyHandle snapDiffPurgedJobCfh, org.rocksdb.ColumnFamilyHandle snapDiffReportCfh, org.apache.hadoop.hdds.utils.db.CodecRegistry codecRegistry)
     

  • Method Summary

    Modifier and Type
    Method
    Description
    byte[]
    getEntryFromPurgedJobTable(String jobId)
     
    long
    getRunCount()
     
    long
    getSuccessfulRunCount()
     
    org.apache.hadoop.hdds.utils.BackgroundTaskQueue
    getTasks()
     
    void
    run()
     

    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

    • SnapshotDiffCleanupService

      public SnapshotDiffCleanupService(long interval, long serviceTimeout, OzoneManager ozoneManager, org.apache.hadoop.hdds.utils.db.managed.ManagedRocksDB db, org.rocksdb.ColumnFamilyHandle snapDiffJobCfh, org.rocksdb.ColumnFamilyHandle snapDiffPurgedJobCfh, org.rocksdb.ColumnFamilyHandle snapDiffReportCfh, org.apache.hadoop.hdds.utils.db.CodecRegistry codecRegistry)

  • Method Details

    • run

      public void run()

    • getEntryFromPurgedJobTable

      public byte[] getEntryFromPurgedJobTable(String jobId)

    • getTasks

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

    • getRunCount

      public long getRunCount()

    • getSuccessfulRunCount

      public long getSuccessfulRunCount()