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

Class KeyDeletingService

java.lang.Object

org.apache.hadoop.hdds.utils.BackgroundService

org.apache.hadoop.ozone.om.service.AbstractKeyDeletingService

org.apache.hadoop.ozone.om.service.KeyDeletingService

All Implemented Interfaces:

org.apache.hadoop.ozone.lock.BootstrapStateHandler

public class KeyDeletingService
extends AbstractKeyDeletingService

This is the background service to delete keys. Scan the metadata of om periodically to get the keys from DeletedTable and ask scm to delete metadata accordingly, if scm returns success for keys, then clean up those keys.

Nested Class Summary

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

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

Nested classes/interfaces inherited from interface org.apache.hadoop.ozone.lock.BootstrapStateHandler

org.apache.hadoop.ozone.lock.BootstrapStateHandler.Lock

Constructor Summary

Constructors

Constructor	Description
KeyDeletingService(OzoneManager ozoneManager, org.apache.hadoop.hdds.scm.protocol.ScmBlockLocationProtocol scmClient, long serviceInterval, long serviceTimeout, org.apache.hadoop.hdds.conf.ConfigurationSource conf, int keyDeletionCorePoolSize, boolean deepCleanSnapshots)

Method Summary

Modifier and Type	Method	Description
protected void	execTaskCompletion()	Updates ServiceMetrics for the last run of the service.
AtomicLong	getDeletedKeyCount()	Returns the number of keys deleted by the background service.
int	getKeyLimitPerTask()
org.apache.hadoop.hdds.utils.BackgroundTaskQueue	getTasks()
void	setKeyLimitPerTask(int keyLimitPerTask)

Methods inherited from class org.apache.hadoop.ozone.om.service.AbstractKeyDeletingService

getBootstrapStateLock, getCallId, getOzoneManager, getRunCount, isBufferLimitCrossed, resume, submitRequest, submitSetSnapshotRequests, suspend

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

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

KeyDeletingService

public KeyDeletingService(OzoneManager ozoneManager,
 org.apache.hadoop.hdds.scm.protocol.ScmBlockLocationProtocol scmClient,
 long serviceInterval,
 long serviceTimeout,
 org.apache.hadoop.hdds.conf.ConfigurationSource conf,
 int keyDeletionCorePoolSize,
 boolean deepCleanSnapshots)

Method Details

getDeletedKeyCount

public AtomicLong getDeletedKeyCount()

Returns the number of keys deleted by the background service.

Returns:

Long count.

execTaskCompletion

protected void execTaskCompletion()

Updates ServiceMetrics for the last run of the service.

Overrides:

execTaskCompletion in class org.apache.hadoop.hdds.utils.BackgroundService

getTasks

public org.apache.hadoop.hdds.utils.BackgroundTaskQueue getTasks()

Specified by:

getTasks in class org.apache.hadoop.hdds.utils.BackgroundService

getKeyLimitPerTask

public int getKeyLimitPerTask()

setKeyLimitPerTask

public void setKeyLimitPerTask(int keyLimitPerTask)