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

Class OMKeysDeleteResponse

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

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

Direct Known Subclasses:

OMKeysDeleteResponseWithFSO

public class OMKeysDeleteResponse
extends AbstractOMKeyDeleteResponse

Response for DeleteKey request.

Constructor Summary

Constructors

Constructor	Description
OMKeysDeleteResponse(org.apache.hadoop.ozone.protocol.proto.OzoneManagerProtocolProtos.OMResponse omResponse, List<org.apache.hadoop.ozone.om.helpers.OmKeyInfo> keyDeleteList, org.apache.hadoop.ozone.om.helpers.OmBucketInfo omBucketInfo, Map<String,org.apache.hadoop.ozone.om.helpers.OmKeyInfo> openKeyInfoMap)
OMKeysDeleteResponse(org.apache.hadoop.ozone.protocol.proto.OzoneManagerProtocolProtos.OMResponse omResponse, org.apache.hadoop.ozone.om.helpers.BucketLayout bucketLayout)	For when the request is not successful or it is a replay transaction.

Method Summary

Modifier and Type	Method	Description
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.
void	checkAndUpdateDB(org.apache.hadoop.ozone.om.OMMetadataManager omMetadataManager, org.apache.hadoop.hdds.utils.db.BatchOperation batchOperation)	Check if omResponse status is OK.
org.apache.hadoop.ozone.om.helpers.OmBucketInfo	getOmBucketInfo()
List<org.apache.hadoop.ozone.om.helpers.OmKeyInfo>	getOmKeyInfoList()
protected Map<String,org.apache.hadoop.ozone.om.helpers.OmKeyInfo>	getOpenKeyInfoMap()

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

addDeletionToBatch, addDeletionToBatch

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

getBucketLayout

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

checkStatusNotOK, getOmLockDetails, getOMResponse, setOmLockDetails

Methods inherited from class java.lang.Object

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

Constructor Details

OMKeysDeleteResponse

public OMKeysDeleteResponse(@Nonnull
 org.apache.hadoop.ozone.protocol.proto.OzoneManagerProtocolProtos.OMResponse omResponse,
 @Nonnull
 List<org.apache.hadoop.ozone.om.helpers.OmKeyInfo> keyDeleteList,
 @Nonnull
 org.apache.hadoop.ozone.om.helpers.OmBucketInfo omBucketInfo,
 @Nonnull
 Map<String,org.apache.hadoop.ozone.om.helpers.OmKeyInfo> openKeyInfoMap)

OMKeysDeleteResponse

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

For when the request is not successful or it is a replay transaction. For a successful request, the other constructor should be used.

Method Details

checkAndUpdateDB

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

Description copied from class: OMClientResponse

Check if omResponse status is OK. If yes, add to DB. For OmResponse with failure, this should do nothing. This method is not called in failure scenario in OM code.

Overrides:

checkAndUpdateDB in class OMClientResponse

Throws:

IOException

addToDBBatch

public 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 AbstractOMKeyDeleteResponse

Throws:

IOException

getOmKeyInfoList

public List<org.apache.hadoop.ozone.om.helpers.OmKeyInfo> getOmKeyInfoList()

getOmBucketInfo

public org.apache.hadoop.ozone.om.helpers.OmBucketInfo getOmBucketInfo()

getOpenKeyInfoMap

protected Map<String,org.apache.hadoop.ozone.om.helpers.OmKeyInfo> getOpenKeyInfoMap()