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

Class OmKeysDeleteRequestWithFSO

java.lang.Object

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

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

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

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

All Implemented Interfaces:

RequestAuditor

public class OmKeysDeleteRequestWithFSO
extends OMKeysDeleteRequest

Handles DeleteKeys request for recursive bucket deletion.

Nested Class Summary

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

OMClientRequest.Result

Constructor Summary

Constructors

Constructor	Description
OmKeysDeleteRequestWithFSO(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	addKeyToAppropriateList(List<org.apache.hadoop.ozone.om.helpers.OmKeyInfo> omKeyInfoList, org.apache.hadoop.ozone.om.helpers.OmKeyInfo omKeyInfo, List<org.apache.hadoop.ozone.om.helpers.OmKeyInfo> dirList, org.apache.hadoop.ozone.om.helpers.OzoneFileStatus keyStatus)
protected OMClientResponse	getOmClientResponse(OzoneManager ozoneManager, List<org.apache.hadoop.ozone.om.helpers.OmKeyInfo> omKeyInfoList, List<org.apache.hadoop.ozone.om.helpers.OmKeyInfo> dirList, org.apache.hadoop.ozone.protocol.proto.OzoneManagerProtocolProtos.OMResponse.Builder omResponse, org.apache.hadoop.ozone.protocol.proto.OzoneManagerProtocolProtos.DeleteKeyArgs.Builder unDeletedKeys, Map<String,org.apache.hadoop.ozone.om.helpers.ErrorInfo> keyToErrors, boolean deleteStatus, org.apache.hadoop.ozone.om.helpers.OmBucketInfo omBucketInfo, long volumeId, Map<String,org.apache.hadoop.ozone.om.helpers.OmKeyInfo> openKeyInfoMap)
protected org.apache.hadoop.ozone.om.helpers.OmKeyInfo	getOmKeyInfo(OzoneManager ozoneManager, org.apache.hadoop.ozone.om.OMMetadataManager omMetadataManager, String volumeName, String bucketName, String keyName)
protected org.apache.hadoop.ozone.om.helpers.OzoneFileStatus	getOzoneKeyStatus(OzoneManager ozoneManager, org.apache.hadoop.ozone.om.OMMetadataManager omMetadataManager, String volumeName, String bucketName, String keyName)
protected org.apache.commons.lang3.tuple.Pair<Long,Integer>	markKeysAsDeletedInCache(OzoneManager ozoneManager, long trxnLogIndex, List<org.apache.hadoop.ozone.om.helpers.OmKeyInfo> omKeyInfoList, List<org.apache.hadoop.ozone.om.helpers.OmKeyInfo> dirList, org.apache.hadoop.ozone.om.OMMetadataManager omMetadataManager, Map<String,org.apache.hadoop.ozone.om.helpers.OmKeyInfo> openKeyInfoMap)

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

addDeletedKeys, blockDeleteKeysWithBucketLayoutFromOldClient, 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, preExecute, 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

OmKeysDeleteRequestWithFSO

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

Method Details

getOmKeyInfo

protected org.apache.hadoop.ozone.om.helpers.OmKeyInfo getOmKeyInfo(OzoneManager ozoneManager,
 org.apache.hadoop.ozone.om.OMMetadataManager omMetadataManager,
 String volumeName,
 String bucketName,
 String keyName)
                                                             throws IOException

Overrides:

getOmKeyInfo in class OMKeysDeleteRequest

Throws:

IOException

addKeyToAppropriateList

protected void addKeyToAppropriateList(List<org.apache.hadoop.ozone.om.helpers.OmKeyInfo> omKeyInfoList,
 org.apache.hadoop.ozone.om.helpers.OmKeyInfo omKeyInfo,
 List<org.apache.hadoop.ozone.om.helpers.OmKeyInfo> dirList,
 org.apache.hadoop.ozone.om.helpers.OzoneFileStatus keyStatus)

Overrides:

addKeyToAppropriateList in class OMKeysDeleteRequest

getOzoneKeyStatus

protected org.apache.hadoop.ozone.om.helpers.OzoneFileStatus getOzoneKeyStatus(OzoneManager ozoneManager,
 org.apache.hadoop.ozone.om.OMMetadataManager omMetadataManager,
 String volumeName,
 String bucketName,
 String keyName)
                                                                        throws IOException

Overrides:

getOzoneKeyStatus in class OMKeysDeleteRequest

Throws:

IOException

markKeysAsDeletedInCache

protected org.apache.commons.lang3.tuple.Pair<Long,Integer> markKeysAsDeletedInCache(OzoneManager ozoneManager,
 long trxnLogIndex,
 List<org.apache.hadoop.ozone.om.helpers.OmKeyInfo> omKeyInfoList,
 List<org.apache.hadoop.ozone.om.helpers.OmKeyInfo> dirList,
 org.apache.hadoop.ozone.om.OMMetadataManager omMetadataManager,
 Map<String,org.apache.hadoop.ozone.om.helpers.OmKeyInfo> openKeyInfoMap)
                                                                              throws IOException

Overrides:

markKeysAsDeletedInCache in class OMKeysDeleteRequest

Throws:

IOException

getOmClientResponse

@Nonnull
protected OMClientResponse getOmClientResponse(OzoneManager ozoneManager,
 List<org.apache.hadoop.ozone.om.helpers.OmKeyInfo> omKeyInfoList,
 List<org.apache.hadoop.ozone.om.helpers.OmKeyInfo> dirList,
 org.apache.hadoop.ozone.protocol.proto.OzoneManagerProtocolProtos.OMResponse.Builder omResponse,
 org.apache.hadoop.ozone.protocol.proto.OzoneManagerProtocolProtos.DeleteKeyArgs.Builder unDeletedKeys,
 Map<String,org.apache.hadoop.ozone.om.helpers.ErrorInfo> keyToErrors,
 boolean deleteStatus,
 org.apache.hadoop.ozone.om.helpers.OmBucketInfo omBucketInfo,
 long volumeId,
 Map<String,org.apache.hadoop.ozone.om.helpers.OmKeyInfo> openKeyInfoMap)

Overrides:

getOmClientResponse in class OMKeysDeleteRequest