Uses of Class
org.apache.hadoop.ozone.s3.exception.OS3Exception
Packages that use OS3Exception
Package
Description
Rest endpoint implementation for the s3 gateway.
This package contains Ozone S3 exceptions.
This package contains Ozone S3 Authorization header.
This package contains Ozone S3 Util classes.
-
Uses of OS3Exception in org.apache.hadoop.ozone.s3.endpoint
Methods in org.apache.hadoop.ozone.s3.endpoint that throw OS3ExceptionModifier and TypeMethodDescriptionjavax.ws.rs.core.ResponseObjectEndpoint.completeMultipartUpload(String bucket, String key, String uploadID, CompleteMultipartUploadRequest multipartUploadRequest) Complete a multipart upload.protected StringEndpointBase.createS3Bucket(String bucketName) Create an S3Bucket, and also it creates mapping needed to access via ozone and S3.javax.ws.rs.core.ResponseRest endpoint to delete specific bucket.javax.ws.rs.core.ResponseDelete a specific object from a bucket, if query param uploadId is specified, this request is for abort multipart upload.protected voidEndpointBase.deleteS3Bucket(String s3BucketName) Deletes an s3 bucket and removes mapping of Ozone volume/bucket.javax.ws.rs.core.ResponseBucketEndpoint.get(String bucketName, String delimiter, String encodingType, String marker, int maxKeys, String prefix, String continueToken, String startAfter, String uploads, String aclMarker, String keyMarker, String uploadIdMarker, int maxUploads) Rest endpoint to list objects in a specific bucket.javax.ws.rs.core.ResponseObjectEndpoint.get(String bucketName, String keyPath, int partNumber, String uploadId, int maxParts, String partNumberMarker, String taggingMarker) Rest endpoint to download object from a bucket, if query param uploadId is specified, request for list parts of a multipart upload key with specific uploadId.javax.ws.rs.core.ResponseRootEndpoint.get()Rest endpoint to list all the buckets of the current user.Implement acl get.protected org.apache.hadoop.ozone.client.OzoneBucketprotected org.apache.hadoop.ozone.client.OzoneBucketEndpointBase.getCustomMetadataFromHeaders(javax.ws.rs.core.MultivaluedMap<String, String> requestHeaders) static EnumSet<org.apache.hadoop.ozone.security.acl.IAccessAuthorizer.ACLType> S3Acl.getOzoneAclOnBucketFromS3Permission(String permission) static EnumSet<org.apache.hadoop.ozone.security.acl.IAccessAuthorizer.ACLType> S3Acl.getOzoneAclOnVolumeFromS3Permission(String permission) EndpointBase.getTaggingFromHeaders(javax.ws.rs.core.HttpHeaders httpHeaders) javax.ws.rs.core.ResponseRest endpoint to check the existence of a bucket.javax.ws.rs.core.ResponseRest endpoint to check existence of an object in a bucket.javax.ws.rs.core.ResponseObjectEndpoint.initializeMultipartUpload(String bucket, String key) Initialize MultiPartUpload request.javax.ws.rs.core.ResponseBucketEndpoint.listMultipartUploads(String bucketName, String prefix, String keyMarker, String uploadIdMarker, int maxUploads) protected Iterator<? extends org.apache.hadoop.ozone.client.OzoneBucket> EndpointBase.listS3Buckets(String prefix, String previousBucket, Consumer<org.apache.hadoop.ozone.client.OzoneVolume> volumeProcessor) Returns Iterator to iterate over all buckets after prevBucket for a specific user.protected Iterator<? extends org.apache.hadoop.ozone.client.OzoneBucket> EndpointBase.listS3Buckets(String prefix, Consumer<org.apache.hadoop.ozone.client.OzoneVolume> volumeProcessor) Returns Iterator to iterate over all buckets for a specific user.BucketEndpoint.multiDelete(String bucketName, String delete, MultiDeleteRequest request) Implement multi delete.ObjectEndpoint.parseSourceHeader(String copyHeader) Parse the key and bucket name from copy header.javax.ws.rs.core.ResponseBucketEndpoint.put(String bucketName, String aclMarker, InputStream body) javax.ws.rs.core.ResponseObjectEndpoint.put(String bucketName, String keyPath, long length, int partNumber, String uploadID, String taggingMarker, String aclMarker, InputStream body) Rest endpoint to upload object to a bucket.javax.ws.rs.core.ResponseBucketEndpoint.putAcl(String bucketName, InputStream body) Implement acl put.static List<org.apache.hadoop.ozone.OzoneAcl> S3Acl.s3AclToOzoneNativeAclOnBucket(S3BucketAcl bucketAcl) static List<org.apache.hadoop.ozone.OzoneAcl> S3Acl.s3AclToOzoneNativeAclOnVolume(S3BucketAcl bucketAcl) EndpointBase.validateAndGetTagging(List<KV> tagList, Function<KV, String> getTagKey, Function<KV, String> getTagValue) static voidS3Owner.verifyBucketOwnerCondition(javax.ws.rs.core.HttpHeaders headers, String bucketName, String bucketOwner) Verify the bucket owner condition.static voidS3Owner.verifyBucketOwnerConditionOnCopyOperation(javax.ws.rs.core.HttpHeaders headers, String sourceBucketName, String sourceOwner, String destBucketName, String destOwner) Verify the bucket owner condition on copy operation. -
Uses of OS3Exception in org.apache.hadoop.ozone.s3.exception
Fields in org.apache.hadoop.ozone.s3.exception declared as OS3ExceptionModifier and TypeFieldDescriptionstatic final OS3ExceptionS3ErrorTable.ACCESS_DENIEDstatic final OS3ExceptionS3ErrorTable.AUTH_PROTOCOL_NOT_SUPPORTEDstatic final OS3ExceptionS3ErrorTable.BUCKET_ALREADY_EXISTSstatic final OS3ExceptionS3ErrorTable.BUCKET_NOT_EMPTYstatic final OS3ExceptionS3ErrorTable.BUCKET_OWNER_MISMATCHstatic final OS3ExceptionS3ErrorTable.ENTITY_TOO_SMALLstatic final OS3ExceptionS3ErrorTable.INTERNAL_ERRORstatic final OS3ExceptionS3ErrorTable.INVALID_ARGUMENTstatic final OS3ExceptionS3ErrorTable.INVALID_BUCKET_NAMEstatic final OS3ExceptionS3ErrorTable.INVALID_PARTstatic final OS3ExceptionS3ErrorTable.INVALID_PART_ORDERstatic final OS3ExceptionS3ErrorTable.INVALID_RANGEstatic final OS3ExceptionS3ErrorTable.INVALID_REQUESTstatic final OS3ExceptionS3ErrorTable.INVALID_STORAGE_CLASSstatic final OS3ExceptionS3ErrorTable.INVALID_TAGstatic final OS3ExceptionS3ErrorTable.INVALID_URIstatic final OS3ExceptionS3ErrorTable.MALFORMED_HEADERstatic final OS3ExceptionS3ErrorTable.MALFORMED_XMLstatic final OS3ExceptionS3ErrorTable.METADATA_TOO_LARGEstatic final OS3ExceptionS3ErrorTable.NO_OVERWRITEstatic final OS3ExceptionS3ErrorTable.NO_SUCH_BUCKETstatic final OS3ExceptionS3ErrorTable.NO_SUCH_KEYstatic final OS3ExceptionS3ErrorTable.NO_SUCH_TAG_SETstatic final OS3ExceptionS3ErrorTable.NO_SUCH_UPLOADstatic final OS3ExceptionS3ErrorTable.NO_SUCH_VOLUMEstatic final OS3ExceptionS3ErrorTable.NOT_IMPLEMENTEDstatic final OS3ExceptionS3ErrorTable.PRECOND_FAILEDstatic final OS3ExceptionS3ErrorTable.QUOTA_EXCEEDEDstatic final OS3ExceptionS3ErrorTable.S3_AUTHINFO_CREATION_ERRORMethods in org.apache.hadoop.ozone.s3.exception that return OS3ExceptionModifier and TypeMethodDescriptionstatic OS3ExceptionS3ErrorTable.getInternalError(Exception e) static OS3ExceptionS3ErrorTable.newError(OS3Exception e, String resource) static OS3ExceptionS3ErrorTable.newError(OS3Exception e, String resource, Exception ex) Create a new instance of Error.OS3Exception.withMessage(String message) Create a copy with specific message.Methods in org.apache.hadoop.ozone.s3.exception with parameters of type OS3ExceptionModifier and TypeMethodDescriptionstatic OS3ExceptionS3ErrorTable.newError(OS3Exception e, String resource) static OS3ExceptionS3ErrorTable.newError(OS3Exception e, String resource, Exception ex) Create a new instance of Error.javax.ws.rs.core.ResponseOS3ExceptionMapper.toResponse(OS3Exception exception) -
Uses of OS3Exception in org.apache.hadoop.ozone.s3.signature
Methods in org.apache.hadoop.ozone.s3.signature that throw OS3ExceptionModifier and TypeMethodDescriptionstatic StringStringToSignProducer.buildCanonicalRequest(String schema, String method, String uri, String signedHeaders, Map<String, String> headers, Map<String, String> queryParams, boolean unsignedPayload) AWSSignatureProcessor.parseSignature()SignatureProcessor.parseSignature()API to return string to sign. -
Uses of OS3Exception in org.apache.hadoop.ozone.s3.util
Methods in org.apache.hadoop.ozone.s3.util with parameters of type OS3ExceptionModifier and TypeMethodDescriptionstatic javax.ws.rs.WebApplicationExceptionS3Utils.wrapOS3Exception(OS3Exception ex) Methods in org.apache.hadoop.ozone.s3.util that throw OS3ExceptionModifier and TypeMethodDescriptionstatic ContinueTokenContinueToken.decodeFromString(String key) Decode a continuation token which is used in get Bucket.static org.apache.hadoop.hdds.client.ReplicationConfigS3Utils.resolveS3ClientSideReplicationConfig(String s3StorageTypeHeader, String s3StorageConfigHeader, org.apache.hadoop.hdds.client.ReplicationConfig clientConfiguredReplConfig, org.apache.hadoop.hdds.client.ReplicationConfig bucketReplConfig) This API used to resolve the client side configuration preference for file system layer implementations.static org.apache.hadoop.hdds.client.ReplicationConfigS3Utils.toReplicationConfig(String s3StorageType, String s3StorageConfig) static voidS3Utils.validateMultiChunksUpload(javax.ws.rs.core.HttpHeaders headers, String amzDecodedContentLength, String resource) static StringS3Utils.validateSignatureHeader(javax.ws.rs.core.HttpHeaders headers, String resource, boolean isSignedPayload)