Package org.apache.hadoop.ozone.container.keyvalue.statemachine.background

Class BlockDeletingTask

java.lang.Object

org.apache.hadoop.ozone.container.keyvalue.statemachine.background.BlockDeletingTask

All Implemented Interfaces:

Callable<org.apache.hadoop.hdds.utils.BackgroundTaskResult>, org.apache.hadoop.hdds.utils.BackgroundTask

public class BlockDeletingTask
extends Object
implements org.apache.hadoop.hdds.utils.BackgroundTask

BlockDeletingTask for KeyValueContainer.

Constructor Summary

Constructors

Constructor	Description
BlockDeletingTask(BlockDeletingService blockDeletingService, BlockDeletingService.ContainerBlockInfo containerBlockInfo, ContainerChecksumTreeManager checksumTreeManager, int priority)

Method Summary

Modifier and Type	Method	Description
org.apache.hadoop.hdds.utils.BackgroundTaskResult	call()
boolean	checkDataDir(File dataDir)
org.apache.hadoop.ozone.container.keyvalue.statemachine.background.BlockDeletingTask.ContainerBackgroundTaskResult	deleteViaSchema1(DBHandle meta, Container container, File dataDir, long startTime)
org.apache.hadoop.ozone.container.keyvalue.statemachine.background.BlockDeletingTask.ContainerBackgroundTaskResult	deleteViaSchema2(DBHandle meta, Container container, File dataDir, long startTime)
org.apache.hadoop.ozone.container.keyvalue.statemachine.background.BlockDeletingTask.ContainerBackgroundTaskResult	deleteViaSchema3(DBHandle meta, Container container, File dataDir, long startTime)
Duration	getBlockDeletingMaxLockHoldingTime()
int	getPriority()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

BlockDeletingTask

public BlockDeletingTask(BlockDeletingService blockDeletingService,
 BlockDeletingService.ContainerBlockInfo containerBlockInfo,
 ContainerChecksumTreeManager checksumTreeManager,
 int priority)

Method Details

call

public org.apache.hadoop.hdds.utils.BackgroundTaskResult call()
                                                       throws Exception

Specified by:

call in interface org.apache.hadoop.hdds.utils.BackgroundTask

Specified by:

call in interface Callable<org.apache.hadoop.hdds.utils.BackgroundTaskResult>

Throws:

Exception

checkDataDir

public boolean checkDataDir(File dataDir)

deleteViaSchema1

public org.apache.hadoop.ozone.container.keyvalue.statemachine.background.BlockDeletingTask.ContainerBackgroundTaskResult deleteViaSchema1(DBHandle meta,
 Container container,
 File dataDir,
 long startTime)
                                                                                                                                    throws IOException

Throws:

IOException

deleteViaSchema2

public org.apache.hadoop.ozone.container.keyvalue.statemachine.background.BlockDeletingTask.ContainerBackgroundTaskResult deleteViaSchema2(DBHandle meta,
 Container container,
 File dataDir,
 long startTime)
                                                                                                                                    throws IOException

Throws:

IOException

deleteViaSchema3

public org.apache.hadoop.ozone.container.keyvalue.statemachine.background.BlockDeletingTask.ContainerBackgroundTaskResult deleteViaSchema3(DBHandle meta,
 Container container,
 File dataDir,
 long startTime)
                                                                                                                                    throws IOException

Throws:

IOException

getPriority

public int getPriority()

Specified by:

getPriority in interface org.apache.hadoop.hdds.utils.BackgroundTask

getBlockDeletingMaxLockHoldingTime

public Duration getBlockDeletingMaxLockHoldingTime()