Package org.apache.hadoop.ozone.om.response.key

Class AbstractOMKeyDeleteResponse

java.lang.Object

org.apache.hadoop.ozone.om.response.OMClientResponse

org.apache.hadoop.ozone.om.response.key.OmKeyResponse

org.apache.hadoop.ozone.om.response.key.AbstractOMKeyDeleteResponse

Direct Known Subclasses:

OMKeyDeleteResponse, OMKeysDeleteResponse, OMOpenKeysDeleteResponse

public abstract class AbstractOMKeyDeleteResponse
extends OmKeyResponse

Base class for responses that need to move keys from an arbitrary table to the deleted table.

Constructor Summary

Constructors

Constructor	Description
AbstractOMKeyDeleteResponse(org.apache.hadoop.ozone.protocol.proto.OzoneManagerProtocolProtos.OMResponse omResponse)
AbstractOMKeyDeleteResponse(org.apache.hadoop.ozone.protocol.proto.OzoneManagerProtocolProtos.OMResponse omResponse, org.apache.hadoop.ozone.om.helpers.BucketLayout bucketLayout)

Method Summary

Modifier and Type	Method	Description
protected void	addDeletionToBatch(org.apache.hadoop.ozone.om.OMMetadataManager omMetadataManager, org.apache.hadoop.hdds.utils.db.BatchOperation batchOperation, org.apache.hadoop.hdds.utils.db.Table<String,?> fromTable, String keyName, String deleteKeyName, org.apache.hadoop.ozone.om.helpers.OmKeyInfo omKeyInfo, long bucketId, boolean isCommittedKey)	This method is used for FSO file deletes.
protected void	addDeletionToBatch(org.apache.hadoop.ozone.om.OMMetadataManager omMetadataManager, org.apache.hadoop.hdds.utils.db.BatchOperation batchOperation, org.apache.hadoop.hdds.utils.db.Table<String,?> fromTable, String keyName, org.apache.hadoop.ozone.om.helpers.OmKeyInfo omKeyInfo, long bucketId, boolean isCommittedKey)	Adds the operation of deleting the keyName omKeyInfo pair from fromTable to the batch operation batchOperation.
abstract void	addToDBBatch(org.apache.hadoop.ozone.om.OMMetadataManager omMetadataManager, org.apache.hadoop.hdds.utils.db.BatchOperation batchOperation)	Implement logic to add the response to batch.

Methods inherited from class org.apache.hadoop.ozone.om.response.key.OmKeyResponse

getBucketLayout

Methods inherited from class org.apache.hadoop.ozone.om.response.OMClientResponse

checkAndUpdateDB, checkStatusNotOK, getOmLockDetails, getOMResponse, setOmLockDetails

Methods inherited from class java.lang.Object

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

Constructor Details

AbstractOMKeyDeleteResponse

public AbstractOMKeyDeleteResponse(@Nonnull
 org.apache.hadoop.ozone.protocol.proto.OzoneManagerProtocolProtos.OMResponse omResponse)

AbstractOMKeyDeleteResponse

public AbstractOMKeyDeleteResponse(@Nonnull
 org.apache.hadoop.ozone.protocol.proto.OzoneManagerProtocolProtos.OMResponse omResponse,
 @Nonnull
 org.apache.hadoop.ozone.om.helpers.BucketLayout bucketLayout)

Method Details

addDeletionToBatch

protected void addDeletionToBatch(org.apache.hadoop.ozone.om.OMMetadataManager omMetadataManager,
 org.apache.hadoop.hdds.utils.db.BatchOperation batchOperation,
 org.apache.hadoop.hdds.utils.db.Table<String,?> fromTable,
 String keyName,
 org.apache.hadoop.ozone.om.helpers.OmKeyInfo omKeyInfo,
 long bucketId,
 boolean isCommittedKey)
                           throws IOException

Adds the operation of deleting the keyName omKeyInfo pair from fromTable to the batch operation batchOperation. The batch operation is not committed, so no changes are persisted to disk. The log transaction index used will be retrieved by calling WithObjectID.getUpdateID() on omKeyInfo.

Throws:

IOException

addDeletionToBatch

protected void addDeletionToBatch(org.apache.hadoop.ozone.om.OMMetadataManager omMetadataManager,
 org.apache.hadoop.hdds.utils.db.BatchOperation batchOperation,
 org.apache.hadoop.hdds.utils.db.Table<String,?> fromTable,
 String keyName,
 String deleteKeyName,
 org.apache.hadoop.ozone.om.helpers.OmKeyInfo omKeyInfo,
 long bucketId,
 boolean isCommittedKey)
                           throws IOException

This method is used for FSO file deletes. Since a common deletedTable is used ,it requires to add key in the full format (vol/buck/key). This method deletes the key from file table (which is in prefix format) and adds the fullKey into the deletedTable

Parameters:

keyName - (format: objectId/key)

deleteKeyName - (format: vol/buck/key/objectId)

omKeyInfo -

Throws:

IOException

addToDBBatch

public abstract void addToDBBatch(org.apache.hadoop.ozone.om.OMMetadataManager omMetadataManager,
 org.apache.hadoop.hdds.utils.db.BatchOperation batchOperation)
                           throws IOException

Description copied from class: OMClientResponse

Implement logic to add the response to batch. This function should be called from checkAndUpdateDB only.

Specified by:

addToDBBatch in class OMClientResponse

Throws:

IOException