Package org.apache.hadoop.ozone.container.common.impl

Class BlockDeletingService

java.lang.Object

org.apache.hadoop.hdds.utils.BackgroundService

org.apache.hadoop.ozone.container.common.impl.BlockDeletingService

public class BlockDeletingService
extends org.apache.hadoop.hdds.utils.BackgroundService

A per-datanode container block deleting service takes in charge of deleting staled ozone blocks.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	BlockDeletingService.ContainerBlockInfo	Pair of container data and the number of blocks to delete.

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

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

Constructor Summary

Constructors

Constructor	Description
BlockDeletingService(OzoneContainer ozoneContainer, long serviceInterval, long serviceTimeout, TimeUnit timeUnit, int workerSize, org.apache.hadoop.hdds.conf.ConfigurationSource conf, String threadNamePrefix, ContainerChecksumTreeManager checksumTreeManager, org.apache.hadoop.hdds.conf.ReconfigurationHandler reconfigurationHandler)
BlockDeletingService(OzoneContainer ozoneContainer, long serviceInterval, long serviceTimeout, TimeUnit timeUnit, int workerSize, org.apache.hadoop.hdds.conf.ConfigurationSource conf, ContainerChecksumTreeManager checksumTreeManager)

Method Summary

Modifier and Type	Method	Description
List<BlockDeletingService.ContainerBlockInfo>	chooseContainerForBlockDeletion(int blockLimit, ContainerDeletionChoosingPolicy deletionPolicy)
Duration	getBlockDeletingMaxLockHoldingTime()
int	getBlockLimitPerInterval()
org.apache.hadoop.hdds.conf.ConfigurationSource	getConf()
BlockDeletingServiceMetrics	getMetrics()
OzoneContainer	getOzoneContainer()
org.apache.hadoop.hdds.utils.BackgroundTaskQueue	getTasks()
void	registerReconfigCallbacks(org.apache.hadoop.hdds.conf.ReconfigurationHandler handler)
void	updateAndRestart(org.apache.hadoop.hdds.conf.OzoneConfiguration ozoneConf)

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

BlockDeletingService

public BlockDeletingService(OzoneContainer ozoneContainer,
 long serviceInterval,
 long serviceTimeout,
 TimeUnit timeUnit,
 int workerSize,
 org.apache.hadoop.hdds.conf.ConfigurationSource conf,
 ContainerChecksumTreeManager checksumTreeManager)

BlockDeletingService

public BlockDeletingService(OzoneContainer ozoneContainer,
 long serviceInterval,
 long serviceTimeout,
 TimeUnit timeUnit,
 int workerSize,
 org.apache.hadoop.hdds.conf.ConfigurationSource conf,
 String threadNamePrefix,
 ContainerChecksumTreeManager checksumTreeManager,
 org.apache.hadoop.hdds.conf.ReconfigurationHandler reconfigurationHandler)

Method Details

registerReconfigCallbacks

public void registerReconfigCallbacks(org.apache.hadoop.hdds.conf.ReconfigurationHandler handler)

updateAndRestart

public void updateAndRestart(org.apache.hadoop.hdds.conf.OzoneConfiguration ozoneConf)

getTasks

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

Specified by:

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

chooseContainerForBlockDeletion

public List<BlockDeletingService.ContainerBlockInfo> chooseContainerForBlockDeletion(int blockLimit,
 ContainerDeletionChoosingPolicy deletionPolicy)
                                                                              throws org.apache.hadoop.hdds.scm.container.common.helpers.StorageContainerException

Throws:

org.apache.hadoop.hdds.scm.container.common.helpers.StorageContainerException

getOzoneContainer

public OzoneContainer getOzoneContainer()

getConf

public org.apache.hadoop.hdds.conf.ConfigurationSource getConf()

getMetrics

public BlockDeletingServiceMetrics getMetrics()

getBlockDeletingMaxLockHoldingTime

public Duration getBlockDeletingMaxLockHoldingTime()

getBlockLimitPerInterval

public int getBlockLimitPerInterval()