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

Class S3MultipartUploadCommitPartResponse

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.S3MultipartUploadCommitPartResponse

Direct Known Subclasses:

S3MultipartUploadCommitPartResponseWithFSO

public class S3MultipartUploadCommitPartResponse
extends OmKeyResponse

Response for S3MultipartUploadCommitPart request.

Constructor Summary

Constructors

Constructor

Description

S3MultipartUploadCommitPartResponse(org.apache.hadoop.ozone.protocol.proto.OzoneManagerProtocolProtos.OMResponse omResponse, String multipartKey, String openKey, org.apache.hadoop.ozone.om.helpers.OmMultipartKeyInfo omMultipartKeyInfo, Map<String,org.apache.hadoop.ozone.om.helpers.RepeatedOmKeyInfo> keyToDeleteMap, org.apache.hadoop.ozone.om.helpers.OmKeyInfo openPartKeyInfoToBeDeleted, org.apache.hadoop.ozone.om.helpers.OmBucketInfo omBucketInfo, long bucketId, org.apache.hadoop.ozone.om.helpers.BucketLayout bucketLayout)

Regular response. 1.

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.
Map<String,org.apache.hadoop.ozone.om.helpers.RepeatedOmKeyInfo>	getKeyToDelete()

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

S3MultipartUploadCommitPartResponse

public S3MultipartUploadCommitPartResponse(@Nonnull
 org.apache.hadoop.ozone.protocol.proto.OzoneManagerProtocolProtos.OMResponse omResponse,
 String multipartKey,
 String openKey,
 @Nullable
 org.apache.hadoop.ozone.om.helpers.OmMultipartKeyInfo omMultipartKeyInfo,
 @Nullable
 Map<String,org.apache.hadoop.ozone.om.helpers.RepeatedOmKeyInfo> keyToDeleteMap,
 @Nullable
 org.apache.hadoop.ozone.om.helpers.OmKeyInfo openPartKeyInfoToBeDeleted,
 @Nonnull
 org.apache.hadoop.ozone.om.helpers.OmBucketInfo omBucketInfo,
 long bucketId,
 @Nonnull
 org.apache.hadoop.ozone.om.helpers.BucketLayout bucketLayout)

Regular response. 1. Update MultipartKey in MultipartInfoTable with new PartKeyInfo 2. Delete openKey from OpenKeyTable 3. If old key or uncommitted (pseudo) key exists, put it in DeletedTable

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 OMClientResponse

Throws:

IOException

getKeyToDelete

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