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

Class OMKeyCommitResponse

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.OMKeyCommitResponse
Direct Known Subclasses:
OMKeyCommitResponseWithFSO
public class OMKeyCommitResponse extends OmKeyResponse
Response for CommitKey request.

  • Constructor Summary

    Constructors
    Constructor
    Description
    OMKeyCommitResponse(org.apache.hadoop.ozone.protocol.proto.OzoneManagerProtocolProtos.OMResponse omResponse, org.apache.hadoop.ozone.om.helpers.BucketLayout bucketLayout)
    For when the request is not successful.
    OMKeyCommitResponse(org.apache.hadoop.ozone.protocol.proto.OzoneManagerProtocolProtos.OMResponse omResponse, org.apache.hadoop.ozone.om.helpers.OmKeyInfo omKeyInfo, String ozoneKeyName, String openKeyName, org.apache.hadoop.ozone.om.helpers.OmBucketInfo omBucketInfo, Map<String,org.apache.hadoop.ozone.om.helpers.RepeatedOmKeyInfo> keyToDeleteMap, boolean isHSync, org.apache.hadoop.ozone.om.helpers.OmKeyInfo newOpenKeyInfo, String openKeyNameToUpdate, org.apache.hadoop.ozone.om.helpers.OmKeyInfo openKeyToUpdate)
     

  • 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.
    Map<String,org.apache.hadoop.ozone.om.helpers.RepeatedOmKeyInfo>
    getKeysToDelete()
     
    org.apache.hadoop.ozone.om.helpers.OmKeyInfo
    getNewOpenKeyInfo()
     
    protected org.apache.hadoop.ozone.om.helpers.OmBucketInfo
    getOmBucketInfo()
     
    protected org.apache.hadoop.ozone.om.helpers.OmKeyInfo
    getOmKeyInfo()
     
    protected String
    getOpenKeyName()
     
    protected String
    getOzoneKeyName()
     
    protected void
    handleOpenKeyToUpdate(org.apache.hadoop.ozone.om.OMMetadataManager omMetadataManager, org.apache.hadoop.hdds.utils.db.BatchOperation batchOperation)
     
    protected boolean
    isHSync()
     
    protected void
    updateDeletedTable(org.apache.hadoop.ozone.om.OMMetadataManager omMetadataManager, org.apache.hadoop.hdds.utils.db.BatchOperation batchOperation)
     

    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

    • OMKeyCommitResponse

      public OMKeyCommitResponse(@Nonnull org.apache.hadoop.ozone.protocol.proto.OzoneManagerProtocolProtos.OMResponse omResponse, @Nonnull org.apache.hadoop.ozone.om.helpers.OmKeyInfo omKeyInfo, String ozoneKeyName, String openKeyName, @Nonnull org.apache.hadoop.ozone.om.helpers.OmBucketInfo omBucketInfo, Map<String,org.apache.hadoop.ozone.om.helpers.RepeatedOmKeyInfo> keyToDeleteMap, boolean isHSync, org.apache.hadoop.ozone.om.helpers.OmKeyInfo newOpenKeyInfo, String openKeyNameToUpdate, org.apache.hadoop.ozone.om.helpers.OmKeyInfo openKeyToUpdate)

    • OMKeyCommitResponse

      public OMKeyCommitResponse(@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. For a successful request, the other constructor should be used.

  • Method Details

    • 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 OMClientResponse
      Throws:
      IOException

    • getOpenKeyName

      protected String getOpenKeyName()

    • getOmKeyInfo

      protected org.apache.hadoop.ozone.om.helpers.OmKeyInfo getOmKeyInfo()

    • getOmBucketInfo

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

    • getOzoneKeyName

      protected String getOzoneKeyName()

    • getKeysToDelete

      public Map<String,org.apache.hadoop.ozone.om.helpers.RepeatedOmKeyInfo> getKeysToDelete()

    • updateDeletedTable

      protected void updateDeletedTable(org.apache.hadoop.ozone.om.OMMetadataManager omMetadataManager, org.apache.hadoop.hdds.utils.db.BatchOperation batchOperation) throws IOException
      Throws:
      IOException

    • handleOpenKeyToUpdate

      protected void handleOpenKeyToUpdate(org.apache.hadoop.ozone.om.OMMetadataManager omMetadataManager, org.apache.hadoop.hdds.utils.db.BatchOperation batchOperation) throws IOException
      Throws:
      IOException

    • isHSync

      protected boolean isHSync()

    • getNewOpenKeyInfo

      public org.apache.hadoop.ozone.om.helpers.OmKeyInfo getNewOpenKeyInfo()