Uses of Class
org.apache.hadoop.ozone.om.OzoneManager
Packages that use OzoneManager
Package
Description
This package contains the Ozone Manager classes.
This package contains classes for the OM execution implementation.
This package contains Ozone manager helper class.
This package contains classes for the OM Ratis server implementation.
Utility class used by OzoneManager HA.
This package contains classes for handling OMRequests.
Package contains classes related to bucket requests.
This package contains classes for handling acl requests for bucket.
Package contains classes related to file requests.
Package contains classes related to key requests.
Package contains classes related to acl requests for keys.
Package contains classes related to acl requests for prefix.
Package contains classes related to S3 multipart upload requests.
Package contains classes related to S3 security requests.
Package contains classes related to S3 tagging requests.
Package contains classes related to OM tenant requests.
This package contains classes which handle security requests.
Package contains classes related to snapshot requests.
Package contains classes related to upgrade finalization requests.
Package contains helper/utility classes for requests.
Package contains classes related to volume requests.
Package contains classes related to volume acl requests and responses.
The package contains Ozone Manager background services.
This package contains OM Snapshot related classes.
Package containing filter to perform reclaimable check on snapshots.
This package contains OM Upgrade related classes.
OM protocol buffer translators.
Security related classes.
OM native acl implementation.
-
Uses of OzoneManager in org.apache.hadoop.ozone.om
Methods in org.apache.hadoop.ozone.om that return OzoneManagerModifier and TypeMethodDescriptionstatic OzoneManagerOzoneManager.createOm(org.apache.hadoop.hdds.conf.OzoneConfiguration conf) Constructs OM instance based on the configuration.static OzoneManagerOzoneManager.createOm(org.apache.hadoop.hdds.conf.OzoneConfiguration conf, OzoneManager.StartupOption startupOption) OmMetadataManagerImpl.getOzoneManager()Methods in org.apache.hadoop.ozone.om with parameters of type OzoneManagerModifier and TypeMethodDescriptionstatic booleanOMMultiTenantManager.checkAndEnableMultiTenancy(OzoneManager ozoneManager, org.apache.hadoop.hdds.conf.OzoneConfiguration conf) Returns true if Multi-Tenancy can be successfully enabled given the OM instance and conf; returns false if ozone.om.multitenancy.enabled = false Config validation will be performed on conf if the intent to enable Multi-Tenancy is specified (i.e. ozone.om.multitenancy.enabled = true), if the validation failed, an exception will be thrown to prevent OM from starting up.static org.apache.hadoop.hdds.client.ReplicationConfigOzoneConfigUtil.resolveReplicationConfigPreference(org.apache.hadoop.hdds.protocol.proto.HddsProtos.ReplicationType clientType, org.apache.hadoop.hdds.protocol.proto.HddsProtos.ReplicationFactor clientFactor, org.apache.hadoop.hdds.protocol.proto.HddsProtos.ECReplicationConfig clientECReplicationConfig, org.apache.hadoop.hdds.client.DefaultReplicationConfig bucketDefaultReplicationConfig, OzoneManager ozoneManager) Constructors in org.apache.hadoop.ozone.om with parameters of type OzoneManagerModifierConstructorDescriptionBucketManagerImpl(OzoneManager ozoneManager, org.apache.hadoop.ozone.om.OMMetadataManager metadataManager) KeyManagerImpl(OzoneManager om, ScmClient scmClient, org.apache.hadoop.hdds.conf.OzoneConfiguration conf, OMPerformanceMetrics metrics) KeyManagerImpl(OzoneManager om, ScmClient scmClient, org.apache.hadoop.ozone.om.OMMetadataManager metadataManager, org.apache.hadoop.hdds.conf.OzoneConfiguration conf, org.apache.hadoop.hdds.security.token.OzoneBlockTokenSecretManager secretManager, org.apache.hadoop.crypto.key.KeyProviderCryptoExtension kmsProvider, OMPerformanceMetrics metrics) OmMetadataManagerImpl(org.apache.hadoop.hdds.conf.OzoneConfiguration conf, OzoneManager ozoneManager) OmMetadataManagerImpl constructor.OmMetadataReader(KeyManager keyManager, PrefixManager prefixManager, OzoneManager ozoneManager, org.slf4j.Logger log, org.apache.hadoop.ozone.audit.AuditLogger audit, OmMetadataReaderMetrics omMetadataReaderMetrics, org.apache.hadoop.ozone.security.acl.IAccessAuthorizer accessAuthorizer) OMMultiTenantManagerImpl(OzoneManager ozoneManager, org.apache.hadoop.hdds.conf.OzoneConfiguration conf) OmSnapshot(KeyManager keyManager, PrefixManager prefixManager, OzoneManager ozoneManager, String volumeName, String bucketName, String snapshotName, UUID snapshotID) OmSnapshotManager(OzoneManager ozoneManager) OzoneManagerHttpServer(org.apache.hadoop.hdds.conf.MutableConfigurationSource conf, OzoneManager om) OzoneTrash(org.apache.hadoop.fs.FileSystem fs, org.apache.hadoop.conf.Configuration conf, OzoneManager om) PrefixManagerImpl(OzoneManager ozoneManager, org.apache.hadoop.ozone.om.OMMetadataManager metadataManager, boolean isRatisEnabled) SnapshotDefragService(long interval, TimeUnit unit, long serviceTimeout, OzoneManager ozoneManager, org.apache.hadoop.hdds.conf.OzoneConfiguration configuration) SstFilteringService(long interval, TimeUnit unit, long serviceTimeout, OzoneManager ozoneManager, org.apache.hadoop.hdds.conf.OzoneConfiguration configuration) TrashOzoneFileSystem(OzoneManager ozoneManager) -
Uses of OzoneManager in org.apache.hadoop.ozone.om.execution
Constructors in org.apache.hadoop.ozone.om.execution with parameters of type OzoneManager -
Uses of OzoneManager in org.apache.hadoop.ozone.om.helpers
Methods in org.apache.hadoop.ozone.om.helpers with parameters of type OzoneManagerModifier and TypeMethodDescriptionstatic voidOMAuditLogger.log(OMAuditLogger.Builder builder, OMClientRequest request, OzoneManager om, org.apache.ratis.server.protocol.TermIndex termIndex, Throwable th) -
Uses of OzoneManager in org.apache.hadoop.ozone.om.ratis
Methods in org.apache.hadoop.ozone.om.ratis that return OzoneManagerMethods in org.apache.hadoop.ozone.om.ratis with parameters of type OzoneManagerModifier and TypeMethodDescriptionstatic OzoneManagerRatisServerOzoneManagerRatisServer.newOMRatisServer(org.apache.hadoop.hdds.conf.ConfigurationSource ozoneConf, OzoneManager omProtocol, org.apache.hadoop.ozone.om.helpers.OMNodeDetails omNodeDetails, Map<String, org.apache.hadoop.ozone.om.helpers.OMNodeDetails> peerNodes, org.apache.hadoop.hdds.security.SecurityConfig secConfig, org.apache.hadoop.hdds.security.x509.certificate.client.CertificateClient certClient, boolean isBootstrapping) Creates an instance of OzoneManagerRatisServer. -
Uses of OzoneManager in org.apache.hadoop.ozone.om.ratis.utils
Methods in org.apache.hadoop.ozone.om.ratis.utils with parameters of type OzoneManagerModifier and TypeMethodDescriptionstatic voidOzoneManagerRatisUtils.checkLeaderStatus(OzoneManager ozoneManager) static OMClientRequestOzoneManagerRatisUtils.createClientRequest(org.apache.hadoop.ozone.protocol.proto.OzoneManagerProtocolProtos.OMRequest omRequest, OzoneManager ozoneManager) Create OMClientRequest which encapsulates the OMRequest.static org.apache.hadoop.ozone.protocol.proto.OzoneManagerProtocolProtos.OMResponseOzoneManagerRatisUtils.submitRequest(OzoneManager om, org.apache.hadoop.ozone.protocol.proto.OzoneManagerProtocolProtos.OMRequest omRequest, org.apache.ratis.protocol.ClientId clientId, long callId) -
Uses of OzoneManager in org.apache.hadoop.ozone.om.request
Methods in org.apache.hadoop.ozone.om.request with parameters of type OzoneManagerModifier and TypeMethodDescriptionvoidOMClientRequest.checkAcls(OzoneManager ozoneManager, org.apache.hadoop.ozone.security.acl.OzoneObj.ResourceType resType, org.apache.hadoop.ozone.security.acl.OzoneObj.StoreType storeType, org.apache.hadoop.ozone.security.acl.IAccessAuthorizer.ACLType aclType, String vol, String bucket, String key) Check Acls of ozone object.voidOMClientRequest.checkAcls(OzoneManager ozoneManager, org.apache.hadoop.ozone.security.acl.OzoneObj.ResourceType resType, org.apache.hadoop.ozone.security.acl.OzoneObj.StoreType storeType, org.apache.hadoop.ozone.security.acl.IAccessAuthorizer.ACLType aclType, String vol, String bucket, String key, String volOwner) Check Acls of ozone object with volOwner given.voidOMClientRequest.checkAcls(OzoneManager ozoneManager, org.apache.hadoop.ozone.security.acl.OzoneObj.ResourceType resType, org.apache.hadoop.ozone.security.acl.OzoneObj.StoreType storeType, org.apache.hadoop.ozone.security.acl.IAccessAuthorizer.ACLType aclType, String vol, String bucket, String key, String volOwner, String bucketOwner) Check Acls of ozone object with volOwner given.protected voidOMClientRequest.checkACLsWithFSO(OzoneManager ozoneManager, String volumeName, String bucketName, String keyName, org.apache.hadoop.ozone.security.acl.IAccessAuthorizer.ACLType aclType) Check Acls for the ozone key.org.apache.hadoop.ozone.protocol.proto.OzoneManagerProtocolProtos.UserInfoOMClientRequest.getUserIfNotExists(OzoneManager ozoneManager) For non-rpc internal calls Server.getRemoteUser() and Server.getRemoteIp() will be null.voidOMClientRequest.handleRequestFailure(OzoneManager ozoneManager) Performs any request specific failure handling during request submission.org.apache.hadoop.ozone.protocol.proto.OzoneManagerProtocolProtos.OMRequestOMClientRequest.preExecute(OzoneManager ozoneManager) Perform pre-execute steps on a OMRequest.OMClientRequest.validateAndUpdateCache(OzoneManager ozoneManager, long transactionLogIndex) For testing only.abstract OMClientResponseOMClientRequest.validateAndUpdateCache(OzoneManager ozoneManager, ExecutionContext context) Validate the OMRequest and update the cache. -
Uses of OzoneManager in org.apache.hadoop.ozone.om.request.bucket
Methods in org.apache.hadoop.ozone.om.request.bucket with parameters of type OzoneManagerModifier and TypeMethodDescriptionorg.apache.hadoop.ozone.protocol.proto.OzoneManagerProtocolProtos.OMRequestOMBucketCreateRequest.preExecute(OzoneManager ozoneManager) org.apache.hadoop.ozone.protocol.proto.OzoneManagerProtocolProtos.OMRequestOMBucketSetOwnerRequest.preExecute(OzoneManager ozoneManager) org.apache.hadoop.ozone.protocol.proto.OzoneManagerProtocolProtos.OMRequestOMBucketSetPropertyRequest.preExecute(OzoneManager ozoneManager) OMBucketCreateRequest.validateAndUpdateCache(OzoneManager ozoneManager, ExecutionContext context) OMBucketDeleteRequest.validateAndUpdateCache(OzoneManager ozoneManager, ExecutionContext context) OMBucketSetOwnerRequest.validateAndUpdateCache(OzoneManager ozoneManager, ExecutionContext context) OMBucketSetPropertyRequest.validateAndUpdateCache(OzoneManager ozoneManager, ExecutionContext context) -
Uses of OzoneManager in org.apache.hadoop.ozone.om.request.bucket.acl
Methods in org.apache.hadoop.ozone.om.request.bucket.acl with parameters of type OzoneManagerModifier and TypeMethodDescriptionorg.apache.hadoop.ozone.protocol.proto.OzoneManagerProtocolProtos.OMRequestOMBucketAddAclRequest.preExecute(OzoneManager ozoneManager) org.apache.hadoop.ozone.protocol.proto.OzoneManagerProtocolProtos.OMRequestOMBucketRemoveAclRequest.preExecute(OzoneManager ozoneManager) org.apache.hadoop.ozone.protocol.proto.OzoneManagerProtocolProtos.OMRequestOMBucketSetAclRequest.preExecute(OzoneManager ozoneManager) OMBucketAclRequest.validateAndUpdateCache(OzoneManager ozoneManager, ExecutionContext context) OMBucketAddAclRequest.validateAndUpdateCache(OzoneManager ozoneManager, ExecutionContext context) OMBucketRemoveAclRequest.validateAndUpdateCache(OzoneManager ozoneManager, ExecutionContext context) OMBucketSetAclRequest.validateAndUpdateCache(OzoneManager ozoneManager, ExecutionContext context) -
Uses of OzoneManager in org.apache.hadoop.ozone.om.request.file
Methods in org.apache.hadoop.ozone.om.request.file with parameters of type OzoneManagerModifier and TypeMethodDescriptionstatic org.apache.hadoop.ozone.om.helpers.OmKeyInfoOMFileRequest.getKeyParentDir(String volumeName, String bucketName, String toKeyName, OzoneManager ozoneManager, org.apache.hadoop.ozone.om.OMMetadataManager metaMgr) Verify parent exists for the destination path and return destination path parent.org.apache.hadoop.ozone.protocol.proto.OzoneManagerProtocolProtos.OMRequestOMDirectoryCreateRequest.preExecute(OzoneManager ozoneManager) org.apache.hadoop.ozone.protocol.proto.OzoneManagerProtocolProtos.OMRequestOMFileCreateRequest.preExecute(OzoneManager ozoneManager) org.apache.hadoop.ozone.protocol.proto.OzoneManagerProtocolProtos.OMRequestOMRecoverLeaseRequest.preExecute(OzoneManager ozoneManager) OMDirectoryCreateRequest.validateAndUpdateCache(OzoneManager ozoneManager, ExecutionContext context) OMDirectoryCreateRequestWithFSO.validateAndUpdateCache(OzoneManager ozoneManager, ExecutionContext context) OMFileCreateRequest.validateAndUpdateCache(OzoneManager ozoneManager, ExecutionContext context) OMFileCreateRequestWithFSO.validateAndUpdateCache(OzoneManager ozoneManager, ExecutionContext context) OMRecoverLeaseRequest.validateAndUpdateCache(OzoneManager ozoneManager, ExecutionContext context) -
Uses of OzoneManager in org.apache.hadoop.ozone.om.request.key
Methods in org.apache.hadoop.ozone.om.request.key with parameters of type OzoneManagerModifier and TypeMethodDescriptionOMKeyRequest.addKeyInfoToDeleteMap(OzoneManager om, long trxnLogIndex, String ozoneKey, long bucketId, org.apache.hadoop.ozone.om.helpers.OmKeyInfo keyInfo, Map<String, org.apache.hadoop.ozone.om.helpers.RepeatedOmKeyInfo> deleteMap) protected voidOMKeyRequest.checkBucketAcls(OzoneManager ozoneManager, String volume, String bucket, String key, org.apache.hadoop.ozone.security.acl.IAccessAuthorizer.ACLType aclType) Check Acls for the ozone bucket.protected voidOMKeyRequest.checkKeyAcls(OzoneManager ozoneManager, String volume, String bucket, String key, org.apache.hadoop.ozone.security.acl.IAccessAuthorizer.ACLType aclType, org.apache.hadoop.ozone.security.acl.OzoneObj.ResourceType resourceType) Check Acls for the ozone key.protected voidOMKeyRequest.checkKeyAcls(OzoneManager ozoneManager, String volume, String bucket, String key, org.apache.hadoop.ozone.security.acl.IAccessAuthorizer.ACLType aclType, org.apache.hadoop.ozone.security.acl.OzoneObj.ResourceType resourceType, String volumeOwner) Check Acls for the ozone key with volumeOwner.protected voidOMKeyRequest.checkKeyAclsInOpenKeyTable(OzoneManager ozoneManager, String volume, String bucket, String key, org.apache.hadoop.ozone.security.acl.IAccessAuthorizer.ACLType aclType, long clientId) Check ACLs for Ozone Key in OpenKey table if ozone native authorizer is enabled.protected voidOMKeyRequest.generateRequiredEncryptionInfo(org.apache.hadoop.ozone.protocol.proto.OzoneManagerProtocolProtos.KeyArgs keyArgs, org.apache.hadoop.ozone.protocol.proto.OzoneManagerProtocolProtos.KeyArgs.Builder newKeyArgs, OzoneManager ozoneManager) Generate EncryptionInfo and set in to newKeyArgs.protected List<org.apache.hadoop.ozone.om.helpers.OmDirectoryInfo> OMKeyRequest.getAllMissingParentDirInfo(OzoneManager ozoneManager, org.apache.hadoop.ozone.protocol.proto.OzoneManagerProtocolProtos.KeyArgs keyArgs, org.apache.hadoop.ozone.om.helpers.OmBucketInfo bucketInfo, OMFileRequest.OMPathInfoWithFSO pathInfo, long trxnLogIndex) Construct OmDirectoryInfo for every parent directory in missing list.protected List<org.apache.hadoop.ozone.om.helpers.OmKeyInfo> OMKeyRequest.getAllParentInfo(OzoneManager ozoneManager, org.apache.hadoop.ozone.protocol.proto.OzoneManagerProtocolProtos.KeyArgs keyArgs, List<String> missingParents, org.apache.hadoop.ozone.om.helpers.OmBucketInfo bucketInfo, OMFileRequest.OMPathInfo omPathInfo, long trxnLogIndex) Construct OmKeyInfo for every parent directory in missing list.protected static Optional<org.apache.hadoop.fs.FileEncryptionInfo> OMKeyRequest.getFileEncryptionInfo(OzoneManager ozoneManager, org.apache.hadoop.ozone.om.helpers.OmBucketInfo bucketInfo) protected voidOMKeyRequest.getFileEncryptionInfoForMpuKey(org.apache.hadoop.ozone.protocol.proto.OzoneManagerProtocolProtos.KeyArgs keyArgs, org.apache.hadoop.ozone.protocol.proto.OzoneManagerProtocolProtos.KeyArgs.Builder newKeyArgs, OzoneManager ozoneManager) protected OMClientResponseOMKeysDeleteRequest.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 OMClientResponseOmKeysDeleteRequestWithFSO.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.OmKeyInfoOMKeysDeleteRequest.getOmKeyInfo(OzoneManager ozoneManager, org.apache.hadoop.ozone.om.OMMetadataManager omMetadataManager, String volume, String bucket, String key) protected org.apache.hadoop.ozone.om.helpers.OmKeyInfoOmKeysDeleteRequestWithFSO.getOmKeyInfo(OzoneManager ozoneManager, org.apache.hadoop.ozone.om.OMMetadataManager omMetadataManager, String volumeName, String bucketName, String keyName) protected List<org.apache.hadoop.ozone.om.helpers.OmKeyLocationInfo> OMKeyCommitRequest.getOmKeyLocationInfos(OzoneManager ozoneManager, org.apache.hadoop.ozone.protocol.proto.OzoneManagerProtocolProtos.KeyArgs commitKeyArgs) protected org.apache.hadoop.ozone.om.helpers.OzoneFileStatusOMKeysDeleteRequest.getOzoneKeyStatus(OzoneManager ozoneManager, org.apache.hadoop.ozone.om.OMMetadataManager omMetadataManager, String volumeName, String bucketName, String keyName) protected org.apache.hadoop.ozone.om.helpers.OzoneFileStatusOmKeysDeleteRequestWithFSO.getOzoneKeyStatus(OzoneManager ozoneManager, org.apache.hadoop.ozone.om.OMMetadataManager omMetadataManager, String volumeName, String bucketName, String keyName) protected OzoneLockStrategyOMKeyRequest.getOzoneLockStrategy(OzoneManager ozoneManager) OMKeysDeleteRequest.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) OmKeysDeleteRequestWithFSO.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) org.apache.hadoop.ozone.protocol.proto.OzoneManagerProtocolProtos.OMRequestOMAllocateBlockRequest.preExecute(OzoneManager ozoneManager) org.apache.hadoop.ozone.protocol.proto.OzoneManagerProtocolProtos.OMRequestOMKeyCommitRequest.preExecute(OzoneManager ozoneManager) org.apache.hadoop.ozone.protocol.proto.OzoneManagerProtocolProtos.OMRequestOMKeyCreateRequest.preExecute(OzoneManager ozoneManager) org.apache.hadoop.ozone.protocol.proto.OzoneManagerProtocolProtos.OMRequestOMKeyDeleteRequest.preExecute(OzoneManager ozoneManager) org.apache.hadoop.ozone.protocol.proto.OzoneManagerProtocolProtos.OMRequestOMKeyRenameRequest.preExecute(OzoneManager ozoneManager) org.apache.hadoop.ozone.protocol.proto.OzoneManagerProtocolProtos.OMRequestOMKeySetTimesRequest.preExecute(OzoneManager ozoneManager) org.apache.hadoop.ozone.protocol.proto.OzoneManagerProtocolProtos.OMRequestOMKeySetTimesRequestWithFSO.preExecute(OzoneManager ozoneManager) protected org.apache.hadoop.ozone.protocol.proto.OzoneManagerProtocolProtos.KeyArgsOMKeyDeleteRequest.resolveBucketAndCheckAcls(OzoneManager ozoneManager, org.apache.hadoop.ozone.protocol.proto.OzoneManagerProtocolProtos.KeyArgs.Builder newKeyArgs) protected org.apache.hadoop.ozone.protocol.proto.OzoneManagerProtocolProtos.KeyArgsOMKeyDeleteRequestWithFSO.resolveBucketAndCheckAcls(OzoneManager ozoneManager, org.apache.hadoop.ozone.protocol.proto.OzoneManagerProtocolProtos.KeyArgs.Builder newKeyArgs) protected org.apache.hadoop.ozone.protocol.proto.OzoneManagerProtocolProtos.KeyArgsOMKeyRenameRequest.resolveBucketAndCheckAcls(org.apache.hadoop.ozone.protocol.proto.OzoneManagerProtocolProtos.KeyArgs keyArgs, OzoneManager ozoneManager, String fromKeyName, String toKeyName) protected org.apache.hadoop.ozone.protocol.proto.OzoneManagerProtocolProtos.KeyArgsOMKeyRenameRequestWithFSO.resolveBucketAndCheckAcls(org.apache.hadoop.ozone.protocol.proto.OzoneManagerProtocolProtos.KeyArgs keyArgs, OzoneManager ozoneManager, String fromKeyName, String toKeyName) protected org.apache.hadoop.ozone.protocol.proto.OzoneManagerProtocolProtos.KeyArgsOMKeyRequest.resolveBucketAndCheckKeyAcls(org.apache.hadoop.ozone.protocol.proto.OzoneManagerProtocolProtos.KeyArgs keyArgs, OzoneManager ozoneManager, org.apache.hadoop.ozone.security.acl.IAccessAuthorizer.ACLType aclType) protected org.apache.hadoop.ozone.protocol.proto.OzoneManagerProtocolProtos.KeyArgsOMKeyRequest.resolveBucketAndCheckKeyAclsWithFSO(org.apache.hadoop.ozone.protocol.proto.OzoneManagerProtocolProtos.KeyArgs keyArgs, OzoneManager ozoneManager, org.apache.hadoop.ozone.security.acl.IAccessAuthorizer.ACLType aclType) protected org.apache.hadoop.ozone.protocol.proto.OzoneManagerProtocolProtos.KeyArgsOMKeyRequest.resolveBucketAndCheckOpenKeyAcls(org.apache.hadoop.ozone.protocol.proto.OzoneManagerProtocolProtos.KeyArgs keyArgs, OzoneManager ozoneManager, org.apache.hadoop.ozone.security.acl.IAccessAuthorizer.ACLType aclType, long clientId) protected org.apache.hadoop.ozone.protocol.proto.OzoneManagerProtocolProtos.KeyArgsOMKeyRequest.resolveBucketLink(OzoneManager ozoneManager, org.apache.hadoop.ozone.protocol.proto.OzoneManagerProtocolProtos.KeyArgs keyArgs) protected org.apache.hadoop.ozone.protocol.proto.OzoneManagerProtocolProtos.KeyArgsOMKeyRequest.resolveBucketLink(OzoneManager ozoneManager, org.apache.hadoop.ozone.protocol.proto.OzoneManagerProtocolProtos.KeyArgs keyArgs, Map<String, String> auditMap) protected voidOMOpenKeysDeleteRequest.updateOpenKeyTableCache(OzoneManager ozoneManager, long trxnLogIndex, org.apache.hadoop.ozone.protocol.proto.OzoneManagerProtocolProtos.OpenKeyBucket keysPerBucket, Map<String, org.apache.commons.lang3.tuple.Pair<Long, org.apache.hadoop.ozone.om.helpers.OmKeyInfo>> deletedOpenKeys) OMAllocateBlockRequest.validateAndUpdateCache(OzoneManager ozoneManager, ExecutionContext context) OMAllocateBlockRequestWithFSO.validateAndUpdateCache(OzoneManager ozoneManager, ExecutionContext context) OMDirectoriesPurgeRequestWithFSO.validateAndUpdateCache(OzoneManager ozoneManager, ExecutionContext context) OMKeyCommitRequest.validateAndUpdateCache(OzoneManager ozoneManager, ExecutionContext context) OMKeyCommitRequestWithFSO.validateAndUpdateCache(OzoneManager ozoneManager, ExecutionContext context) OMKeyCreateRequest.validateAndUpdateCache(OzoneManager ozoneManager, ExecutionContext context) OMKeyCreateRequestWithFSO.validateAndUpdateCache(OzoneManager ozoneManager, ExecutionContext context) OMKeyDeleteRequest.validateAndUpdateCache(OzoneManager ozoneManager, ExecutionContext context) OMKeyDeleteRequestWithFSO.validateAndUpdateCache(OzoneManager ozoneManager, ExecutionContext context) OMKeyPurgeRequest.validateAndUpdateCache(OzoneManager ozoneManager, ExecutionContext context) OMKeyRenameRequest.validateAndUpdateCache(OzoneManager ozoneManager, ExecutionContext context) OMKeyRenameRequestWithFSO.validateAndUpdateCache(OzoneManager ozoneManager, ExecutionContext context) OMKeysDeleteRequest.validateAndUpdateCache(OzoneManager ozoneManager, ExecutionContext context) OMKeySetTimesRequest.validateAndUpdateCache(OzoneManager ozoneManager, ExecutionContext context) OMKeySetTimesRequestWithFSO.validateAndUpdateCache(OzoneManager ozoneManager, ExecutionContext context) OMKeysRenameRequest.validateAndUpdateCache(OzoneManager ozoneManager, ExecutionContext context) OMOpenKeysDeleteRequest.validateAndUpdateCache(OzoneManager ozoneManager, ExecutionContext context) -
Uses of OzoneManager in org.apache.hadoop.ozone.om.request.key.acl
Methods in org.apache.hadoop.ozone.om.request.key.acl with parameters of type OzoneManagerModifier and TypeMethodDescriptionvoidOMKeyAclRequest.initializeBucketLayout(OzoneManager ozoneManager) org.apache.hadoop.ozone.protocol.proto.OzoneManagerProtocolProtos.OMRequestOMKeyAddAclRequest.preExecute(OzoneManager ozoneManager) org.apache.hadoop.ozone.protocol.proto.OzoneManagerProtocolProtos.OMRequestOMKeyAddAclRequestWithFSO.preExecute(OzoneManager ozoneManager) org.apache.hadoop.ozone.protocol.proto.OzoneManagerProtocolProtos.OMRequestOMKeyRemoveAclRequest.preExecute(OzoneManager ozoneManager) org.apache.hadoop.ozone.protocol.proto.OzoneManagerProtocolProtos.OMRequestOMKeyRemoveAclRequestWithFSO.preExecute(OzoneManager ozoneManager) org.apache.hadoop.ozone.protocol.proto.OzoneManagerProtocolProtos.OMRequestOMKeySetAclRequest.preExecute(OzoneManager ozoneManager) org.apache.hadoop.ozone.protocol.proto.OzoneManagerProtocolProtos.OMRequestOMKeySetAclRequestWithFSO.preExecute(OzoneManager ozoneManager) OMKeyAclRequest.validateAndUpdateCache(OzoneManager ozoneManager, ExecutionContext context) OMKeyAclRequestWithFSO.validateAndUpdateCache(OzoneManager ozoneManager, ExecutionContext context) OMKeyAddAclRequest.validateAndUpdateCache(OzoneManager ozoneManager, ExecutionContext context) OMKeyAddAclRequestWithFSO.validateAndUpdateCache(OzoneManager ozoneManager, ExecutionContext context) OMKeyRemoveAclRequest.validateAndUpdateCache(OzoneManager ozoneManager, ExecutionContext context) OMKeyRemoveAclRequestWithFSO.validateAndUpdateCache(OzoneManager ozoneManager, ExecutionContext context) OMKeySetAclRequest.validateAndUpdateCache(OzoneManager ozoneManager, ExecutionContext context) OMKeySetAclRequestWithFSO.validateAndUpdateCache(OzoneManager ozoneManager, ExecutionContext context) Constructors in org.apache.hadoop.ozone.om.request.key.acl with parameters of type OzoneManagerModifierConstructorDescriptionOMKeyAddAclRequest(org.apache.hadoop.ozone.protocol.proto.OzoneManagerProtocolProtos.OMRequest omRequest, OzoneManager ozoneManager) OMKeyRemoveAclRequest(org.apache.hadoop.ozone.protocol.proto.OzoneManagerProtocolProtos.OMRequest omRequest, OzoneManager ozoneManager) OMKeySetAclRequest(org.apache.hadoop.ozone.protocol.proto.OzoneManagerProtocolProtos.OMRequest omRequest, OzoneManager ozoneManager) -
Uses of OzoneManager in org.apache.hadoop.ozone.om.request.key.acl.prefix
Methods in org.apache.hadoop.ozone.om.request.key.acl.prefix with parameters of type OzoneManagerModifier and TypeMethodDescriptionOMPrefixAclRequest.validateAndUpdateCache(OzoneManager ozoneManager, ExecutionContext context) -
Uses of OzoneManager in org.apache.hadoop.ozone.om.request.s3.multipart
Methods in org.apache.hadoop.ozone.om.request.s3.multipart with parameters of type OzoneManagerModifier and TypeMethodDescriptionprotected voidS3MultipartUploadCompleteRequest.checkDirectoryAlreadyExists(OzoneManager ozoneManager, org.apache.hadoop.ozone.om.helpers.OmBucketInfo omBucketInfo, String keyName, org.apache.hadoop.ozone.om.OMMetadataManager omMetadataManager) protected voidS3MultipartUploadCompleteRequestWithFSO.checkDirectoryAlreadyExists(OzoneManager ozoneManager, org.apache.hadoop.ozone.om.helpers.OmBucketInfo omBucketInfo, String keyName, org.apache.hadoop.ozone.om.OMMetadataManager omMetadataManager) protected OMClientResponseS3MultipartUploadAbortRequest.getOmClientResponse(OzoneManager ozoneManager, org.apache.hadoop.ozone.om.helpers.OmMultipartKeyInfo multipartKeyInfo, String multipartKey, String multipartOpenKey, org.apache.hadoop.ozone.protocol.proto.OzoneManagerProtocolProtos.OMResponse.Builder omResponse, org.apache.hadoop.ozone.om.helpers.OmBucketInfo omBucketInfo) protected OMClientResponseS3MultipartUploadAbortRequestWithFSO.getOmClientResponse(OzoneManager ozoneManager, org.apache.hadoop.ozone.om.helpers.OmMultipartKeyInfo multipartKeyInfo, String multipartKey, String multipartOpenKey, org.apache.hadoop.ozone.protocol.proto.OzoneManagerProtocolProtos.OMResponse.Builder omResponse, org.apache.hadoop.ozone.om.helpers.OmBucketInfo omBucketInfo) protected S3MultipartUploadCommitPartResponseS3MultipartUploadCommitPartRequest.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 S3MultipartUploadCommitPartResponseS3MultipartUploadCommitPartRequestWithFSO.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 voidS3InitiateMultipartUploadRequest.logResult(OzoneManager ozoneManager, org.apache.hadoop.ozone.protocol.proto.OzoneManagerProtocolProtos.MultipartInfoInitiateRequest multipartInfoInitiateRequest, Map<String, String> auditMap, String volumeName, String bucketName, String keyName, Exception exception, OMClientRequest.Result result) protected voidS3MultipartUploadCompleteRequest.logResult(OzoneManager ozoneManager, org.apache.hadoop.ozone.protocol.proto.OzoneManagerProtocolProtos.MultipartUploadCompleteRequest multipartUploadCompleteRequest, List<org.apache.hadoop.ozone.protocol.proto.OzoneManagerProtocolProtos.Part> partsList, Map<String, String> auditMap, String volumeName, String bucketName, String keyName, Exception exception, OMClientRequest.Result result) org.apache.hadoop.ozone.protocol.proto.OzoneManagerProtocolProtos.OMRequestS3InitiateMultipartUploadRequest.preExecute(OzoneManager ozoneManager) org.apache.hadoop.ozone.protocol.proto.OzoneManagerProtocolProtos.OMRequestS3MultipartUploadAbortRequest.preExecute(OzoneManager ozoneManager) org.apache.hadoop.ozone.protocol.proto.OzoneManagerProtocolProtos.OMRequestS3MultipartUploadCommitPartRequest.preExecute(OzoneManager ozoneManager) org.apache.hadoop.ozone.protocol.proto.OzoneManagerProtocolProtos.OMRequestS3MultipartUploadCompleteRequest.preExecute(OzoneManager ozoneManager) S3ExpiredMultipartUploadsAbortRequest.validateAndUpdateCache(OzoneManager ozoneManager, ExecutionContext context) S3InitiateMultipartUploadRequest.validateAndUpdateCache(OzoneManager ozoneManager, ExecutionContext context) S3InitiateMultipartUploadRequestWithFSO.validateAndUpdateCache(OzoneManager ozoneManager, ExecutionContext context) S3MultipartUploadAbortRequest.validateAndUpdateCache(OzoneManager ozoneManager, ExecutionContext context) S3MultipartUploadCommitPartRequest.validateAndUpdateCache(OzoneManager ozoneManager, ExecutionContext context) S3MultipartUploadCompleteRequest.validateAndUpdateCache(OzoneManager ozoneManager, ExecutionContext context) -
Uses of OzoneManager in org.apache.hadoop.ozone.om.request.s3.security
Methods in org.apache.hadoop.ozone.om.request.s3.security with parameters of type OzoneManagerModifier and TypeMethodDescriptionstatic voidS3SecretRequestHelper.checkAccessIdSecretOpPermission(OzoneManager ozoneManager, org.apache.hadoop.security.UserGroupInformation ugi, String accessId) Checks whether the ugi has the permission to operate (get secret, set secret, revoke secret) on the given access ID.org.apache.hadoop.ozone.protocol.proto.OzoneManagerProtocolProtos.OMRequestOMSetSecretRequest.preExecute(OzoneManager ozoneManager) org.apache.hadoop.ozone.protocol.proto.OzoneManagerProtocolProtos.OMRequestS3GetSecretRequest.preExecute(OzoneManager ozoneManager) org.apache.hadoop.ozone.protocol.proto.OzoneManagerProtocolProtos.OMRequestS3RevokeSecretRequest.preExecute(OzoneManager ozoneManager) OMSetSecretRequest.validateAndUpdateCache(OzoneManager ozoneManager, ExecutionContext context) S3GetSecretRequest.validateAndUpdateCache(OzoneManager ozoneManager, ExecutionContext context) S3RevokeSecretRequest.validateAndUpdateCache(OzoneManager ozoneManager, ExecutionContext context) -
Uses of OzoneManager in org.apache.hadoop.ozone.om.request.s3.tagging
Methods in org.apache.hadoop.ozone.om.request.s3.tagging with parameters of type OzoneManagerModifier and TypeMethodDescriptionorg.apache.hadoop.ozone.protocol.proto.OzoneManagerProtocolProtos.OMRequestS3DeleteObjectTaggingRequest.preExecute(OzoneManager ozoneManager) org.apache.hadoop.ozone.protocol.proto.OzoneManagerProtocolProtos.OMRequestS3PutObjectTaggingRequest.preExecute(OzoneManager ozoneManager) S3DeleteObjectTaggingRequest.validateAndUpdateCache(OzoneManager ozoneManager, ExecutionContext context) S3DeleteObjectTaggingRequestWithFSO.validateAndUpdateCache(OzoneManager ozoneManager, ExecutionContext context) S3PutObjectTaggingRequest.validateAndUpdateCache(OzoneManager ozoneManager, ExecutionContext context) S3PutObjectTaggingRequestWithFSO.validateAndUpdateCache(OzoneManager ozoneManager, ExecutionContext context) -
Uses of OzoneManager in org.apache.hadoop.ozone.om.request.s3.tenant
Methods in org.apache.hadoop.ozone.om.request.s3.tenant with parameters of type OzoneManagerModifier and TypeMethodDescriptionorg.apache.hadoop.ozone.protocol.proto.OzoneManagerProtocolProtos.OMRequestOMTenantAssignAdminRequest.preExecute(OzoneManager ozoneManager) org.apache.hadoop.ozone.protocol.proto.OzoneManagerProtocolProtos.OMRequestOMTenantAssignUserAccessIdRequest.preExecute(OzoneManager ozoneManager) org.apache.hadoop.ozone.protocol.proto.OzoneManagerProtocolProtos.OMRequestOMTenantCreateRequest.preExecute(OzoneManager ozoneManager) org.apache.hadoop.ozone.protocol.proto.OzoneManagerProtocolProtos.OMRequestOMTenantDeleteRequest.preExecute(OzoneManager ozoneManager) org.apache.hadoop.ozone.protocol.proto.OzoneManagerProtocolProtos.OMRequestOMTenantRevokeAdminRequest.preExecute(OzoneManager ozoneManager) org.apache.hadoop.ozone.protocol.proto.OzoneManagerProtocolProtos.OMRequestOMTenantRevokeUserAccessIdRequest.preExecute(OzoneManager ozoneManager) OMSetRangerServiceVersionRequest.validateAndUpdateCache(OzoneManager ozoneManager, ExecutionContext context) OMTenantAssignAdminRequest.validateAndUpdateCache(OzoneManager ozoneManager, ExecutionContext context) OMTenantAssignUserAccessIdRequest.validateAndUpdateCache(OzoneManager ozoneManager, ExecutionContext context) OMTenantCreateRequest.validateAndUpdateCache(OzoneManager ozoneManager, ExecutionContext context) OMTenantDeleteRequest.validateAndUpdateCache(OzoneManager ozoneManager, ExecutionContext context) OMTenantRevokeAdminRequest.validateAndUpdateCache(OzoneManager ozoneManager, ExecutionContext context) OMTenantRevokeUserAccessIdRequest.validateAndUpdateCache(OzoneManager ozoneManager, ExecutionContext context) -
Uses of OzoneManager in org.apache.hadoop.ozone.om.request.security
Methods in org.apache.hadoop.ozone.om.request.security with parameters of type OzoneManagerModifier and TypeMethodDescriptionorg.apache.hadoop.ozone.protocol.proto.OzoneManagerProtocolProtos.OMRequestOMCancelDelegationTokenRequest.preExecute(OzoneManager ozoneManager) org.apache.hadoop.ozone.protocol.proto.OzoneManagerProtocolProtos.OMRequestOMGetDelegationTokenRequest.preExecute(OzoneManager ozoneManager) org.apache.hadoop.ozone.protocol.proto.OzoneManagerProtocolProtos.OMRequestOMRenewDelegationTokenRequest.preExecute(OzoneManager ozoneManager) OMCancelDelegationTokenRequest.validateAndUpdateCache(OzoneManager ozoneManager, ExecutionContext context) OMGetDelegationTokenRequest.validateAndUpdateCache(OzoneManager ozoneManager, ExecutionContext context) OMRenewDelegationTokenRequest.validateAndUpdateCache(OzoneManager ozoneManager, ExecutionContext context) -
Uses of OzoneManager in org.apache.hadoop.ozone.om.request.snapshot
Methods in org.apache.hadoop.ozone.om.request.snapshot with parameters of type OzoneManagerModifier and TypeMethodDescriptionorg.apache.hadoop.ozone.protocol.proto.OzoneManagerProtocolProtos.OMRequestOMSnapshotCreateRequest.preExecute(OzoneManager ozoneManager) org.apache.hadoop.ozone.protocol.proto.OzoneManagerProtocolProtos.OMRequestOMSnapshotDeleteRequest.preExecute(OzoneManager ozoneManager) org.apache.hadoop.ozone.protocol.proto.OzoneManagerProtocolProtos.OMRequestOMSnapshotMoveTableKeysRequest.preExecute(OzoneManager ozoneManager) org.apache.hadoop.ozone.protocol.proto.OzoneManagerProtocolProtos.OMRequestOMSnapshotRenameRequest.preExecute(OzoneManager ozoneManager) static voidOMSnapshotMoveUtils.updateCache(OzoneManager ozoneManager, org.apache.hadoop.ozone.om.helpers.SnapshotInfo fromSnapshot, org.apache.hadoop.ozone.om.helpers.SnapshotInfo toSnapshot, ExecutionContext context) OMSnapshotCreateRequest.validateAndUpdateCache(OzoneManager ozoneManager, ExecutionContext context) OMSnapshotDeleteRequest.validateAndUpdateCache(OzoneManager ozoneManager, ExecutionContext context) OMSnapshotMoveDeletedKeysRequest.validateAndUpdateCache(OzoneManager ozoneManager, ExecutionContext context) OMSnapshotMoveTableKeysRequest.validateAndUpdateCache(OzoneManager ozoneManager, ExecutionContext context) OMSnapshotPurgeRequest.validateAndUpdateCache(OzoneManager ozoneManager, ExecutionContext context) OMSnapshotRenameRequest.validateAndUpdateCache(OzoneManager ozoneManager, ExecutionContext context) OMSnapshotSetPropertyRequest.validateAndUpdateCache(OzoneManager ozoneManager, ExecutionContext context) -
Uses of OzoneManager in org.apache.hadoop.ozone.om.request.upgrade
Methods in org.apache.hadoop.ozone.om.request.upgrade with parameters of type OzoneManagerModifier and TypeMethodDescriptionOMCancelPrepareRequest.validateAndUpdateCache(OzoneManager ozoneManager, ExecutionContext context) OMFinalizeUpgradeRequest.validateAndUpdateCache(OzoneManager ozoneManager, ExecutionContext context) OMPrepareRequest.validateAndUpdateCache(OzoneManager ozoneManager, ExecutionContext context) -
Uses of OzoneManager in org.apache.hadoop.ozone.om.request.util
Methods in org.apache.hadoop.ozone.om.request.util with parameters of type OzoneManagerModifier and TypeMethodDescriptionOMEchoRPCWriteRequest.validateAndUpdateCache(OzoneManager ozoneManager, ExecutionContext context) -
Uses of OzoneManager in org.apache.hadoop.ozone.om.request.volume
Methods in org.apache.hadoop.ozone.om.request.volume with parameters of type OzoneManagerModifier and TypeMethodDescriptionorg.apache.hadoop.ozone.protocol.proto.OzoneManagerProtocolProtos.OMRequestOMQuotaRepairRequest.preExecute(OzoneManager ozoneManager) org.apache.hadoop.ozone.protocol.proto.OzoneManagerProtocolProtos.OMRequestOMVolumeCreateRequest.preExecute(OzoneManager ozoneManager) org.apache.hadoop.ozone.protocol.proto.OzoneManagerProtocolProtos.OMRequestOMVolumeSetOwnerRequest.preExecute(OzoneManager ozoneManager) org.apache.hadoop.ozone.protocol.proto.OzoneManagerProtocolProtos.OMRequestOMVolumeSetQuotaRequest.preExecute(OzoneManager ozoneManager) OMQuotaRepairRequest.validateAndUpdateCache(OzoneManager ozoneManager, ExecutionContext context) OMVolumeCreateRequest.validateAndUpdateCache(OzoneManager ozoneManager, ExecutionContext context) OMVolumeDeleteRequest.validateAndUpdateCache(OzoneManager ozoneManager, ExecutionContext context) OMVolumeSetOwnerRequest.validateAndUpdateCache(OzoneManager ozoneManager, ExecutionContext context) OMVolumeSetQuotaRequest.validateAndUpdateCache(OzoneManager ozoneManager, ExecutionContext context) -
Uses of OzoneManager in org.apache.hadoop.ozone.om.request.volume.acl
Methods in org.apache.hadoop.ozone.om.request.volume.acl with parameters of type OzoneManagerModifier and TypeMethodDescriptionorg.apache.hadoop.ozone.protocol.proto.OzoneManagerProtocolProtos.OMRequestOMVolumeAddAclRequest.preExecute(OzoneManager ozoneManager) org.apache.hadoop.ozone.protocol.proto.OzoneManagerProtocolProtos.OMRequestOMVolumeRemoveAclRequest.preExecute(OzoneManager ozoneManager) org.apache.hadoop.ozone.protocol.proto.OzoneManagerProtocolProtos.OMRequestOMVolumeSetAclRequest.preExecute(OzoneManager ozoneManager) OMVolumeAclRequest.validateAndUpdateCache(OzoneManager ozoneManager, ExecutionContext context) OMVolumeAddAclRequest.validateAndUpdateCache(OzoneManager ozoneManager, ExecutionContext context) OMVolumeRemoveAclRequest.validateAndUpdateCache(OzoneManager ozoneManager, ExecutionContext context) OMVolumeSetAclRequest.validateAndUpdateCache(OzoneManager ozoneManager, ExecutionContext context) -
Uses of OzoneManager in org.apache.hadoop.ozone.om.service
Methods in org.apache.hadoop.ozone.om.service that return OzoneManagerConstructors in org.apache.hadoop.ozone.om.service with parameters of type OzoneManagerModifierConstructorDescriptionAbstractKeyDeletingService(String serviceName, long interval, TimeUnit unit, int threadPoolSize, long serviceTimeout, OzoneManager ozoneManager) CompactDBService(OzoneManager ozoneManager) CompactionService(OzoneManager ozoneManager, TimeUnit unit, long interval, long timeout, List<String> tables) DirectoryDeletingService(long interval, TimeUnit unit, long serviceTimeout, OzoneManager ozoneManager, org.apache.hadoop.hdds.conf.OzoneConfiguration configuration, int dirDeletingServiceCorePoolSize, boolean deepCleanSnapshots) KeyDeletingService(OzoneManager ozoneManager, org.apache.hadoop.hdds.scm.protocol.ScmBlockLocationProtocol scmClient, long serviceInterval, long serviceTimeout, org.apache.hadoop.hdds.conf.ConfigurationSource conf, int keyDeletionCorePoolSize, boolean deepCleanSnapshots) MultipartUploadCleanupService(long interval, TimeUnit unit, long timeout, OzoneManager ozoneManager, org.apache.hadoop.hdds.conf.ConfigurationSource conf) OMRangerBGSyncService(OzoneManager ozoneManager, OMMultiTenantManager omMultiTenantManager, MultiTenantAccessController accessController, long interval, TimeUnit unit, long serviceTimeout) OpenKeyCleanupService(long interval, TimeUnit unit, long timeout, OzoneManager ozoneManager, org.apache.hadoop.hdds.conf.ConfigurationSource conf) QuotaRepairTask(OzoneManager ozoneManager) SnapshotDeletingService(long interval, long serviceTimeout, OzoneManager ozoneManager) SnapshotDiffCleanupService(long interval, long serviceTimeout, OzoneManager ozoneManager, org.apache.hadoop.hdds.utils.db.managed.ManagedRocksDB db, org.rocksdb.ColumnFamilyHandle snapDiffJobCfh, org.rocksdb.ColumnFamilyHandle snapDiffPurgedJobCfh, org.rocksdb.ColumnFamilyHandle snapDiffReportCfh, org.apache.hadoop.hdds.utils.db.CodecRegistry codecRegistry) -
Uses of OzoneManager in org.apache.hadoop.ozone.om.snapshot
Methods in org.apache.hadoop.ozone.om.snapshot with parameters of type OzoneManagerModifier and TypeMethodDescriptionstatic voidSnapshotUtils.checkSnapshotActive(OzoneManager ozoneManager, String snapshotTableKey) Throws OMException FILE_NOT_FOUND if snapshot is not in active status.static org.apache.hadoop.ozone.om.helpers.SnapshotInfoSnapshotUtils.getLatestSnapshotInfo(String volumeName, String bucketName, OzoneManager ozoneManager, SnapshotChainManager snapshotChainManager) static org.apache.hadoop.ozone.om.helpers.SnapshotInfoSnapshotUtils.getNextSnapshot(OzoneManager ozoneManager, SnapshotChainManager chainManager, org.apache.hadoop.ozone.om.helpers.SnapshotInfo snapInfo) Get the next snapshot in the snapshot chain.static org.apache.hadoop.ozone.om.helpers.SnapshotInfoSnapshotUtils.getPreviousSnapshot(OzoneManager ozoneManager, SnapshotChainManager chainManager, org.apache.hadoop.ozone.om.helpers.SnapshotInfo snapInfo) Get the previous snapshot in the snapshot chain.static org.apache.hadoop.ozone.om.helpers.SnapshotInfoSnapshotUtils.getSnapshotInfo(OzoneManager ozoneManager, String snapshotKey) static org.apache.hadoop.ozone.om.helpers.SnapshotInfoSnapshotUtils.getSnapshotInfo(OzoneManager ozoneManager, String volumeName, String bucketName, String snapshotName) static org.apache.hadoop.ozone.om.helpers.SnapshotInfoSnapshotUtils.getSnapshotInfo(OzoneManager ozoneManager, SnapshotChainManager chainManager, UUID snapshotId) Constructors in org.apache.hadoop.ozone.om.snapshot with parameters of type OzoneManagerModifierConstructorDescriptionSnapshotDiffManager(org.apache.hadoop.hdds.utils.db.managed.ManagedRocksDB db, org.apache.ozone.rocksdiff.RocksDBCheckpointDiffer differ, OzoneManager ozoneManager, org.rocksdb.ColumnFamilyHandle snapDiffJobCfh, org.rocksdb.ColumnFamilyHandle snapDiffReportCfh, org.apache.hadoop.hdds.utils.db.managed.ManagedColumnFamilyOptions familyOptions, org.apache.hadoop.hdds.utils.db.CodecRegistry codecRegistry) -
Uses of OzoneManager in org.apache.hadoop.ozone.om.snapshot.filter
Methods in org.apache.hadoop.ozone.om.snapshot.filter that return OzoneManagerConstructors in org.apache.hadoop.ozone.om.snapshot.filter with parameters of type OzoneManagerModifierConstructorDescriptionReclaimableDirFilter(OzoneManager ozoneManager, OmSnapshotManager omSnapshotManager, SnapshotChainManager snapshotChainManager, org.apache.hadoop.ozone.om.helpers.SnapshotInfo currentSnapshotInfo, KeyManager keyManager, org.apache.hadoop.ozone.om.lock.IOzoneManagerLock lock) ReclaimableFilter(OzoneManager ozoneManager, OmSnapshotManager omSnapshotManager, SnapshotChainManager snapshotChainManager, org.apache.hadoop.ozone.om.helpers.SnapshotInfo currentSnapshotInfo, KeyManager keyManager, org.apache.hadoop.ozone.om.lock.IOzoneManagerLock lock, int numberOfPreviousSnapshotsFromChain) Filter to return deleted keys/directories which are reclaimable based on their presence in previous snapshot in the snapshot chain.ReclaimableKeyFilter(OzoneManager ozoneManager, OmSnapshotManager omSnapshotManager, SnapshotChainManager snapshotChainManager, org.apache.hadoop.ozone.om.helpers.SnapshotInfo currentSnapshotInfo, KeyManager keyManager, org.apache.hadoop.ozone.om.lock.IOzoneManagerLock lock) ReclaimableRenameEntryFilter(OzoneManager ozoneManager, OmSnapshotManager omSnapshotManager, SnapshotChainManager snapshotChainManager, org.apache.hadoop.ozone.om.helpers.SnapshotInfo currentSnapshotInfo, KeyManager keyManager, org.apache.hadoop.ozone.om.lock.IOzoneManagerLock lock) -
Uses of OzoneManager in org.apache.hadoop.ozone.om.upgrade
Methods in org.apache.hadoop.ozone.om.upgrade with parameters of type OzoneManagerModifier and TypeMethodDescriptionvoidQuotaRepairUpgradeAction.execute(OzoneManager arg) voidOMUpgradeFinalizer.finalizeLayoutFeature(org.apache.hadoop.ozone.upgrade.LayoutFeature layoutFeature, OzoneManager om) voidOMUpgradeFinalizer.runPrefinalizeStateActions(org.apache.hadoop.ozone.common.Storage storage, OzoneManager om) -
Uses of OzoneManager in org.apache.hadoop.ozone.protocolPB
Methods in org.apache.hadoop.ozone.protocolPB that return OzoneManagerConstructors in org.apache.hadoop.ozone.protocolPB with parameters of type OzoneManagerModifierConstructorDescriptionOMInterServiceProtocolServerSideImpl(OzoneManager ozoneMgr, OzoneManagerRatisServer ratisServer) OzoneManagerProtocolServerSideTranslatorPB(OzoneManager impl, OzoneManagerRatisServer ratisServer, org.apache.hadoop.hdds.utils.ProtocolMessageMetrics<com.google.protobuf.ProtocolMessageEnum> metrics) Constructs an instance of the server handler. -
Uses of OzoneManager in org.apache.hadoop.ozone.security
Methods in org.apache.hadoop.ozone.security with parameters of type OzoneManagerModifier and TypeMethodDescriptionOzoneDelegationTokenSecretManager.Builder.setOzoneManager(OzoneManager ozoneMgr) static voidS3SecurityUtil.validateS3Credential(org.apache.hadoop.ozone.protocol.proto.OzoneManagerProtocolProtos.OMRequest omRequest, OzoneManager ozoneManager) Validate S3 Credentials which are part ofOzoneManagerProtocolProtos.OMRequest. -
Uses of OzoneManager in org.apache.hadoop.ozone.security.acl
Methods in org.apache.hadoop.ozone.security.acl with parameters of type OzoneManagerModifier and TypeMethodDescriptionOzoneManagerAuthorizer.configure(OzoneManager om, KeyManager km, PrefixManager pm) Configure this authorizer.OzoneNativeAuthorizer.configure(OzoneManager om, KeyManager km, PrefixManager pm) static org.apache.hadoop.ozone.security.acl.IAccessAuthorizerOzoneAuthorizerFactory.forOM(OzoneManager om) static org.apache.hadoop.ozone.security.acl.IAccessAuthorizerOzoneAuthorizerFactory.forSnapshot(OzoneManager om, KeyManager keyManager, PrefixManager prefixManager)