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

Class S3MultipartUploadCommitPartRequestWithFSO

java.lang.Object

org.apache.hadoop.ozone.om.request.OMClientRequest

org.apache.hadoop.ozone.om.request.key.OMKeyRequest

org.apache.hadoop.ozone.om.request.s3.multipart.S3MultipartUploadCommitPartRequest

org.apache.hadoop.ozone.om.request.s3.multipart.S3MultipartUploadCommitPartRequestWithFSO

All Implemented Interfaces:

RequestAuditor

public class S3MultipartUploadCommitPartRequestWithFSO
extends S3MultipartUploadCommitPartRequest

Handle Multipart upload commit upload part file.

Nested Class Summary

Nested classes/interfaces inherited from class org.apache.hadoop.ozone.om.request.OMClientRequest

OMClientRequest.Result

Constructor Summary

Constructors

Constructor	Description
S3MultipartUploadCommitPartRequestWithFSO(org.apache.hadoop.ozone.protocol.proto.OzoneManagerProtocolProtos.OMRequest omRequest, org.apache.hadoop.ozone.om.helpers.BucketLayout bucketLayout)

Method Summary

Modifier and Type	Method	Description
protected S3MultipartUploadCommitPartResponse	getOmClientResponse(OzoneManager ozoneManager, Map<String,org.apache.hadoop.ozone.om.helpers.RepeatedOmKeyInfo> keyToDeleteMap, String openKey, org.apache.hadoop.ozone.om.helpers.OmKeyInfo omKeyInfo, String multipartKey, org.apache.hadoop.ozone.om.helpers.OmMultipartKeyInfo multipartKeyInfo, org.apache.hadoop.ozone.protocol.proto.OzoneManagerProtocolProtos.OMResponse build, org.apache.hadoop.ozone.om.helpers.OmBucketInfo omBucketInfo, long bucketId)
protected org.apache.hadoop.ozone.om.helpers.OmKeyInfo	getOmKeyInfo(org.apache.hadoop.ozone.om.OMMetadataManager omMetadataManager, String openKey, String keyName)
protected String	getOpenKey(String volumeName, String bucketName, String keyName, org.apache.hadoop.ozone.om.OMMetadataManager omMetadataManager, long clientID)

Methods inherited from class org.apache.hadoop.ozone.om.request.s3.multipart.S3MultipartUploadCommitPartRequest

blockMPUCommitWithBucketLayoutFromOldClient, disallowCommitMultiPartUploadWithECReplicationConfig, getPartName, preExecute, validateAndUpdateCache

Methods inherited from class org.apache.hadoop.ozone.om.request.key.OMKeyRequest

addKeyInfoToDeleteMap, allocateBlock, checkBucketAcls, checkBucketQuotaInBytes, checkBucketQuotaInNamespace, checkDirectoryAlreadyExists, checkKeyAcls, checkKeyAcls, checkKeyAclsInOpenKeyTable, createDirectoryInfoWithACL, createDirectoryKeyInfoWithACL, createFileInfo, dirKeyInfoBuilderNoACL, filterOutBlocksStillInUse, generateRequiredEncryptionInfo, getAclsForDir, getAclsForKey, getAllMissingParentDirInfo, getAllParentInfo, getBucketInfo, getBucketLayout, getDBMultipartOpenKey, getFileEncryptionInfo, getFileEncryptionInfo, getFileEncryptionInfoForMpuKey, getOldVersionsToCleanUp, getOzoneLockStrategy, getRemoteUser, getVolumeOwner, prepareFileInfo, prepareKeyInfo, resolveBucketAndCheckKeyAcls, resolveBucketAndCheckKeyAclsWithFSO, resolveBucketAndCheckOpenKeyAcls, resolveBucketLink, resolveBucketLink, sumBlockLengths, validateBucketAndVolume, validateEncryptionKeyInfo, wrapUncommittedBlocksAsPseudoKey

Methods inherited from class org.apache.hadoop.ozone.om.request.OMClientRequest

buildAuditMessage, buildVolumeAuditMap, checkAcls, checkAcls, checkAcls, checkACLsWithFSO, createErrorOMResponse, createUGI, createUGIForApi, getAuditBuilder, getHostName, getOmLockDetails, getOmRequest, getRemoteAddress, getUserIfNotExists, getUserInfo, handleRequestFailure, isValidKeyPath, markForAudit, mergeOmLockDetails, normalizeKeyPath, setUGI, validateAndNormalizeKey, validateAndNormalizeKey, validateAndNormalizeKey, validateAndUpdateCache

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.hadoop.ozone.om.request.RequestAuditor

buildKeyArgsAuditMap, buildLightKeyArgsAuditMap

Constructor Details

S3MultipartUploadCommitPartRequestWithFSO

public S3MultipartUploadCommitPartRequestWithFSO(org.apache.hadoop.ozone.protocol.proto.OzoneManagerProtocolProtos.OMRequest omRequest,
 org.apache.hadoop.ozone.om.helpers.BucketLayout bucketLayout)

Method Details

getOpenKey

protected String getOpenKey(String volumeName,
 String bucketName,
 String keyName,
 org.apache.hadoop.ozone.om.OMMetadataManager omMetadataManager,
 long clientID)
                     throws IOException

Overrides:

getOpenKey in class S3MultipartUploadCommitPartRequest

Throws:

IOException

getOmKeyInfo

protected org.apache.hadoop.ozone.om.helpers.OmKeyInfo getOmKeyInfo(org.apache.hadoop.ozone.om.OMMetadataManager omMetadataManager,
 String openKey,
 String keyName)
                                                             throws IOException

Overrides:

getOmKeyInfo in class S3MultipartUploadCommitPartRequest

Throws:

IOException

getOmClientResponse

protected S3MultipartUploadCommitPartResponse getOmClientResponse(OzoneManager ozoneManager,
 Map<String,org.apache.hadoop.ozone.om.helpers.RepeatedOmKeyInfo> keyToDeleteMap,
 String openKey,
 org.apache.hadoop.ozone.om.helpers.OmKeyInfo omKeyInfo,
 String multipartKey,
 org.apache.hadoop.ozone.om.helpers.OmMultipartKeyInfo multipartKeyInfo,
 org.apache.hadoop.ozone.protocol.proto.OzoneManagerProtocolProtos.OMResponse build,
 org.apache.hadoop.ozone.om.helpers.OmBucketInfo omBucketInfo,
 long bucketId)

Overrides:

getOmClientResponse in class S3MultipartUploadCommitPartRequest