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

Class S3MultipartUploadCompleteRequestWithFSO

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

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

All Implemented Interfaces:

RequestAuditor

public class S3MultipartUploadCompleteRequestWithFSO
extends S3MultipartUploadCompleteRequest

Handle Multipart upload complete request.

Nested Class Summary

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

OMClientRequest.Result

Constructor Summary

Constructors

Constructor	Description
S3MultipartUploadCompleteRequestWithFSO(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 void	addKeyTableCacheEntry(org.apache.hadoop.ozone.om.OMMetadataManager omMetadataManager, String ozoneKey, org.apache.hadoop.ozone.om.helpers.OmKeyInfo omKeyInfo, long transactionLogIndex)
protected void	addMissingParentsToCache(org.apache.hadoop.ozone.om.helpers.OmBucketInfo omBucketInfo, List<org.apache.hadoop.ozone.om.helpers.OmDirectoryInfo> missingParentInfos, org.apache.hadoop.ozone.om.OMMetadataManager omMetadataManager, long volumeId, long bucketId, long transactionLogIndex)
protected void	addMultiPartToCache(org.apache.hadoop.ozone.om.OMMetadataManager omMetadataManager, String multipartOpenKey, OMFileRequest.OMPathInfoWithFSO pathInfoFSO, org.apache.hadoop.ozone.om.helpers.OmKeyInfo omKeyInfo, String keyName, long transactionLogIndex)
protected void	checkDirectoryAlreadyExists(OzoneManager ozoneManager, org.apache.hadoop.ozone.om.helpers.OmBucketInfo omBucketInfo, String keyName, org.apache.hadoop.ozone.om.OMMetadataManager omMetadataManager)
org.apache.hadoop.ozone.om.helpers.BucketLayout	getBucketLayout()
protected String	getDBMultipartOpenKey(String volumeName, String bucketName, String keyName, String uploadID, org.apache.hadoop.ozone.om.OMMetadataManager omMetadataManager)	Returns the DB key name of a multipart open key in OM metadata store.
protected String	getDBOzoneKey(org.apache.hadoop.ozone.om.OMMetadataManager omMetadataManager, String volumeName, String bucketName, String keyName)
protected OMClientResponse	getOmClientResponse(String multipartKey, org.apache.hadoop.ozone.protocol.proto.OzoneManagerProtocolProtos.OMResponse.Builder omResponse, String dbMultipartOpenKey, org.apache.hadoop.ozone.om.helpers.OmKeyInfo omKeyInfo, List<org.apache.hadoop.ozone.om.helpers.OmKeyInfo> allKeyInfoToRemove, org.apache.hadoop.ozone.om.helpers.OmBucketInfo omBucketInfo, long volumeId, long bucketId, List<org.apache.hadoop.ozone.om.helpers.OmDirectoryInfo> missingParentInfos, org.apache.hadoop.ozone.om.helpers.OmMultipartKeyInfo multipartKeyInfo)
protected S3MultipartUploadCompleteResponse	getOmClientResponse(org.apache.hadoop.ozone.protocol.proto.OzoneManagerProtocolProtos.OMResponse.Builder omResponse, Exception exception)
protected org.apache.hadoop.ozone.om.helpers.OmKeyInfo	getOmKeyInfoFromKeyTable(String dbOzoneFileKey, String keyName, org.apache.hadoop.ozone.om.OMMetadataManager omMetadataManager)
protected org.apache.hadoop.ozone.om.helpers.OmKeyInfo	getOmKeyInfoFromOpenKeyTable(String dbMultipartKey, String keyName, org.apache.hadoop.ozone.om.OMMetadataManager omMetadataManager)
protected void	updatePrefixFSOInfo(org.apache.hadoop.ozone.om.helpers.OmKeyInfo dbOpenKeyInfo, org.apache.hadoop.ozone.om.helpers.OmKeyInfo.Builder builder)

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

blockMPUCompleteWithBucketLayoutFromOldClient, disallowCompleteMultiPartUploadWithECReplicationConfig, getOmKeyInfo, logResult, 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, 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

S3MultipartUploadCompleteRequestWithFSO

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

Method Details

checkDirectoryAlreadyExists

protected void checkDirectoryAlreadyExists(OzoneManager ozoneManager,
 org.apache.hadoop.ozone.om.helpers.OmBucketInfo omBucketInfo,
 String keyName,
 org.apache.hadoop.ozone.om.OMMetadataManager omMetadataManager)
                                    throws IOException

Overrides:

checkDirectoryAlreadyExists in class S3MultipartUploadCompleteRequest

Throws:

IOException

addMissingParentsToCache

protected void addMissingParentsToCache(org.apache.hadoop.ozone.om.helpers.OmBucketInfo omBucketInfo,
 List<org.apache.hadoop.ozone.om.helpers.OmDirectoryInfo> missingParentInfos,
 org.apache.hadoop.ozone.om.OMMetadataManager omMetadataManager,
 long volumeId,
 long bucketId,
 long transactionLogIndex)
                                 throws IOException

Overrides:

addMissingParentsToCache in class S3MultipartUploadCompleteRequest

Throws:

IOException

addMultiPartToCache

protected void addMultiPartToCache(org.apache.hadoop.ozone.om.OMMetadataManager omMetadataManager,
 String multipartOpenKey,
 OMFileRequest.OMPathInfoWithFSO pathInfoFSO,
 org.apache.hadoop.ozone.om.helpers.OmKeyInfo omKeyInfo,
 String keyName,
 long transactionLogIndex)
                            throws IOException

Overrides:

addMultiPartToCache in class S3MultipartUploadCompleteRequest

Throws:

IOException

getOmKeyInfoFromKeyTable

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

Overrides:

getOmKeyInfoFromKeyTable in class S3MultipartUploadCompleteRequest

Throws:

IOException

getOmKeyInfoFromOpenKeyTable

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

Overrides:

getOmKeyInfoFromOpenKeyTable in class S3MultipartUploadCompleteRequest

Throws:

IOException

addKeyTableCacheEntry

protected void addKeyTableCacheEntry(org.apache.hadoop.ozone.om.OMMetadataManager omMetadataManager,
 String ozoneKey,
 org.apache.hadoop.ozone.om.helpers.OmKeyInfo omKeyInfo,
 long transactionLogIndex)
                              throws IOException

Overrides:

addKeyTableCacheEntry in class S3MultipartUploadCompleteRequest

Throws:

IOException

updatePrefixFSOInfo

protected void updatePrefixFSOInfo(org.apache.hadoop.ozone.om.helpers.OmKeyInfo dbOpenKeyInfo,
 org.apache.hadoop.ozone.om.helpers.OmKeyInfo.Builder builder)

Overrides:

updatePrefixFSOInfo in class S3MultipartUploadCompleteRequest

getDBOzoneKey

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

Overrides:

getDBOzoneKey in class S3MultipartUploadCompleteRequest

Throws:

IOException

getDBMultipartOpenKey

protected String getDBMultipartOpenKey(String volumeName,
 String bucketName,
 String keyName,
 String uploadID,
 org.apache.hadoop.ozone.om.OMMetadataManager omMetadataManager)
                                throws IOException

Description copied from class: OMKeyRequest

Returns the DB key name of a multipart open key in OM metadata store.

Overrides:

getDBMultipartOpenKey in class OMKeyRequest

Parameters:

volumeName - - volume name.

bucketName - - bucket name.

keyName - - key name.

uploadID - - Multi part upload ID for this key.

omMetadataManager -

Returns:

String

Throws:

IOException

getOmClientResponse

protected S3MultipartUploadCompleteResponse getOmClientResponse(org.apache.hadoop.ozone.protocol.proto.OzoneManagerProtocolProtos.OMResponse.Builder omResponse,
 Exception exception)

Overrides:

getOmClientResponse in class S3MultipartUploadCompleteRequest

getOmClientResponse

protected OMClientResponse getOmClientResponse(String multipartKey,
 org.apache.hadoop.ozone.protocol.proto.OzoneManagerProtocolProtos.OMResponse.Builder omResponse,
 String dbMultipartOpenKey,
 org.apache.hadoop.ozone.om.helpers.OmKeyInfo omKeyInfo,
 List<org.apache.hadoop.ozone.om.helpers.OmKeyInfo> allKeyInfoToRemove,
 org.apache.hadoop.ozone.om.helpers.OmBucketInfo omBucketInfo,
 long volumeId,
 long bucketId,
 List<org.apache.hadoop.ozone.om.helpers.OmDirectoryInfo> missingParentInfos,
 org.apache.hadoop.ozone.om.helpers.OmMultipartKeyInfo multipartKeyInfo)

Overrides:

getOmClientResponse in class S3MultipartUploadCompleteRequest

getBucketLayout

public org.apache.hadoop.ozone.om.helpers.BucketLayout getBucketLayout()

Overrides:

getBucketLayout in class OMKeyRequest