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

Class ReclaimableKeyFilter

java.lang.Object

org.apache.hadoop.ozone.om.snapshot.filter.ReclaimableFilter<org.apache.hadoop.ozone.om.helpers.OmKeyInfo>

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

All Implemented Interfaces:

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

public class ReclaimableKeyFilter
extends ReclaimableFilter<org.apache.hadoop.ozone.om.helpers.OmKeyInfo>

Filter to return deleted keys which are reclaimable based on their presence in previous snapshot in the snapshot chain.

Constructor Summary

Constructors

Constructor	Description
ReclaimableKeyFilter(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,org.apache.hadoop.ozone.om.helpers.OmKeyInfo> keyValue)
Map<UUID,Long>	getExclusiveReplicatedSizeMap()
Map<UUID,Long>	getExclusiveSizeMap()
protected String	getVolumeName(org.apache.hadoop.hdds.utils.db.Table.KeyValue<String,org.apache.hadoop.ozone.om.helpers.OmKeyInfo> keyValue)
protected Boolean	isReclaimable(org.apache.hadoop.hdds.utils.db.Table.KeyValue<String,org.apache.hadoop.ozone.om.helpers.OmKeyInfo> deletedKeyInfo)

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

ReclaimableKeyFilter

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

Parameters:

currentSnapshotInfo - : If null the deleted keys in AOS needs to be processed, hence the latest snapshot in the snapshot chain corresponding to bucket key needs to be processed.

keyManager - : keyManager corresponding to snapshot or AOS.

lock - : Lock for Active OM.

Method Details

getVolumeName

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

Specified by:

getVolumeName in class ReclaimableFilter<org.apache.hadoop.ozone.om.helpers.OmKeyInfo>

Throws:

IOException

getBucketName

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

Specified by:

getBucketName in class ReclaimableFilter<org.apache.hadoop.ozone.om.helpers.OmKeyInfo>

Throws:

IOException

isReclaimable

protected Boolean isReclaimable(org.apache.hadoop.hdds.utils.db.Table.KeyValue<String,org.apache.hadoop.ozone.om.helpers.OmKeyInfo> deletedKeyInfo)
                         throws IOException

Specified by:

isReclaimable in class ReclaimableFilter<org.apache.hadoop.ozone.om.helpers.OmKeyInfo>

Throws:

IOException

getExclusiveSizeMap

public Map<UUID,Long> getExclusiveSizeMap()

getExclusiveReplicatedSizeMap

public Map<UUID,Long> getExclusiveReplicatedSizeMap()