Package org.apache.hadoop.ozone.om.snapshot.filter

Class ReclaimableRenameEntryFilter

java.lang.Object

org.apache.hadoop.ozone.om.snapshot.filter.ReclaimableFilter<String>

org.apache.hadoop.ozone.om.snapshot.filter.ReclaimableRenameEntryFilter

All Implemented Interfaces:

Closeable, AutoCloseable, org.apache.ratis.util.function.CheckedFunction<org.apache.hadoop.hdds.utils.db.Table.KeyValue<String,String>,Boolean,IOException>

public class ReclaimableRenameEntryFilter
extends ReclaimableFilter<String>

Class to filter out rename table entries which are reclaimable based on the key presence in previous snapshot's keyTable/DirectoryTable in the snapshot chain.

Constructor Summary

Constructors

Constructor	Description
ReclaimableRenameEntryFilter(OzoneManager ozoneManager, OmSnapshotManager omSnapshotManager, SnapshotChainManager snapshotChainManager, org.apache.hadoop.ozone.om.helpers.SnapshotInfo currentSnapshotInfo, KeyManager keyManager, org.apache.hadoop.ozone.om.lock.IOzoneManagerLock lock)

Method Summary

Modifier and Type	Method	Description
protected String	getBucketName(org.apache.hadoop.hdds.utils.db.Table.KeyValue<String,String> keyValue)
protected String	getVolumeName(org.apache.hadoop.hdds.utils.db.Table.KeyValue<String,String> keyValue)
protected Boolean	isReclaimable(org.apache.hadoop.hdds.utils.db.Table.KeyValue<String,String> renameEntry)	Function which checks whether the objectId corresponding to the rename entry exists in the previous snapshot.

Methods inherited from class org.apache.hadoop.ozone.om.snapshot.filter.ReclaimableFilter

apply, close, getBucketInfo, getKeyManager, getOzoneManager, getPreviousOmSnapshot, getPreviousSnapshotInfo, getVolumeId

Methods inherited from class java.lang.Object

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

Constructor Details

ReclaimableRenameEntryFilter

public ReclaimableRenameEntryFilter(OzoneManager ozoneManager,
 OmSnapshotManager omSnapshotManager,
 SnapshotChainManager snapshotChainManager,
 org.apache.hadoop.ozone.om.helpers.SnapshotInfo currentSnapshotInfo,
 KeyManager keyManager,
 org.apache.hadoop.ozone.om.lock.IOzoneManagerLock lock)

Method Details

isReclaimable

protected Boolean isReclaimable(org.apache.hadoop.hdds.utils.db.Table.KeyValue<String,String> renameEntry)
                         throws IOException

Function which checks whether the objectId corresponding to the rename entry exists in the previous snapshot. If the entry doesn't exist in the previous keyTable/directoryTable then the rename entry can be deleted since there is no reference for this rename entry.

Specified by:

isReclaimable in class ReclaimableFilter<String>

Returns:

true if there is no reference for the objectId based on the rename entry otherwise false.

Throws:

IOException

getVolumeName

protected String getVolumeName(org.apache.hadoop.hdds.utils.db.Table.KeyValue<String,String> keyValue)
                        throws IOException

Specified by:

getVolumeName in class ReclaimableFilter<String>

Throws:

IOException

getBucketName

protected String getBucketName(org.apache.hadoop.hdds.utils.db.Table.KeyValue<String,String> keyValue)
                        throws IOException

Specified by:

getBucketName in class ReclaimableFilter<String>

Throws:

IOException