Package org.apache.hadoop.ozone.om.response.s3.multipart

Class AbstractS3MultipartAbortResponse

java.lang.Object
org.apache.hadoop.ozone.om.response.OMClientResponse
org.apache.hadoop.ozone.om.response.key.OmKeyResponse
org.apache.hadoop.ozone.om.response.s3.multipart.AbstractS3MultipartAbortResponse
Direct Known Subclasses:
S3ExpiredMultipartUploadsAbortResponse, S3MultipartUploadAbortResponse
public abstract class AbstractS3MultipartAbortResponse extends OmKeyResponse
Base class for responses that need to move multipart info part keys to the deleted table.

  • Constructor Summary

    Constructors
    Constructor
    Description
    AbstractS3MultipartAbortResponse(org.apache.hadoop.ozone.protocol.proto.OzoneManagerProtocolProtos.OMResponse omResponse)
     
    AbstractS3MultipartAbortResponse(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
    addAbortToBatch(org.apache.hadoop.ozone.om.OMMetadataManager omMetadataManager, org.apache.hadoop.hdds.utils.db.BatchOperation batchOperation, String multipartKey, String multipartOpenKey, org.apache.hadoop.ozone.om.helpers.OmMultipartKeyInfo omMultipartKeyInfo, org.apache.hadoop.ozone.om.helpers.OmBucketInfo omBucketInfo, org.apache.hadoop.ozone.om.helpers.BucketLayout bucketLayout)
    Adds the operation of aborting a multipart upload to the batch operation.
    protected void
    addAbortToBatch(org.apache.hadoop.ozone.om.OMMetadataManager omMetadataManager, org.apache.hadoop.hdds.utils.db.BatchOperation batchOperation, org.apache.hadoop.ozone.om.helpers.OmBucketInfo omBucketInfo, List<org.apache.hadoop.ozone.om.helpers.OmMultipartAbortInfo> multipartAbortInfo)
    Adds the operation of aborting a list of multipart uploads under the same bucket.

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

    getBucketLayout

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

    addToDBBatch, 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

    • AbstractS3MultipartAbortResponse

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

    • AbstractS3MultipartAbortResponse

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

  • Method Details

    • addAbortToBatch

      protected void addAbortToBatch(org.apache.hadoop.ozone.om.OMMetadataManager omMetadataManager, org.apache.hadoop.hdds.utils.db.BatchOperation batchOperation, org.apache.hadoop.ozone.om.helpers.OmBucketInfo omBucketInfo, List<org.apache.hadoop.ozone.om.helpers.OmMultipartAbortInfo> multipartAbortInfo) throws IOException
      Adds the operation of aborting a list of multipart uploads under the same bucket.
      Parameters:
      omMetadataManager -
      batchOperation -
      omBucketInfo -
      multipartAbortInfo -
      Throws:
      IOException

    • addAbortToBatch

      protected void addAbortToBatch(org.apache.hadoop.ozone.om.OMMetadataManager omMetadataManager, org.apache.hadoop.hdds.utils.db.BatchOperation batchOperation, String multipartKey, String multipartOpenKey, org.apache.hadoop.ozone.om.helpers.OmMultipartKeyInfo omMultipartKeyInfo, org.apache.hadoop.ozone.om.helpers.OmBucketInfo omBucketInfo, org.apache.hadoop.ozone.om.helpers.BucketLayout bucketLayout) throws IOException
      Adds the operation of aborting a multipart upload to the batch operation. Both LEGACY/OBS and FSO have similar abort logic. The only difference is the multipartOpenKey used in the openKeyTable and openFileTable.
      Throws:
      IOException