- call() - Method in class alluxio.proxy.s3.CompleteMultipartUploadHandler.CompleteMultipartUploadTask
-
- call(String, S3RestUtils.RestCallable<T>) - Static method in class alluxio.proxy.s3.S3RestUtils
-
- call() - Method in interface alluxio.proxy.s3.S3RestUtils.RestCallable
-
The REST endpoint implementation.
- cancelAbort(FileSystem, FileSystem, String, String, String) - Static method in class alluxio.proxy.s3.MultipartUploadCleaner
-
Cancel schedule task.
- checkIfComplete(String) - Method in class alluxio.proxy.s3.CompleteMultipartUploadHandler.CompleteMultipartUploadTask
-
On any exception, check with Master on if the there's an object file.
- checkIfComplete(String) - Method in class alluxio.proxy.s3.S3ObjectTask.CompleteMultipartUploadTask
-
On any exception, check with Master on if the there's an object file.
- checkPathIsAlluxioDirectory(FileSystem, String, S3AuditContext) - Static method in class alluxio.proxy.s3.S3RestUtils
-
Check if a path in alluxio is a directory.
- checkPathIsAlluxioDirectory(FileSystem, String, S3AuditContext, Cache<String, Boolean>) - Static method in class alluxio.proxy.s3.S3RestUtils
-
Check if a path in alluxio is a directory.
- checkStatusesForUploadId(FileSystem, FileSystem, AlluxioURI, String) - Static method in class alluxio.proxy.s3.S3RestUtils
-
Fetches and returns the corresponding
URIStatus for both
the multipart upload temp directory and the Alluxio S3 metadata file.
- ChunkedEncodingInputStream - Class in alluxio.proxy.s3
-
This input stream decodes an aws-chunked encoded input stream into its original form.
- ChunkedEncodingInputStream(InputStream) - Constructor for class alluxio.proxy.s3.ChunkedEncodingInputStream
-
Creates a FilterInputStream
by assigning the argument in
to the field this.in so as
to remember it for later use.
- cleanupTempPath(String) - Method in class alluxio.proxy.s3.CompleteMultipartUploadHandler.CompleteMultipartUploadTask
-
Cleanup the temp object file for complete multipart upload.
- cleanupTempPath(String) - Method in class alluxio.proxy.s3.S3ObjectTask.CompleteMultipartUploadTask
-
Cleanup the temp object file for complete multipart upload.
- clear() - Method in class alluxio.proxy.s3.TaggingData
-
Removes all tags contained in this object.
- close() - Method in class alluxio.proxy.ProxyMasterSync
-
- close() - Method in class alluxio.proxy.s3.RangeFileInStream
-
- close() - Method in class alluxio.proxy.s3.RateLimitInputStream
-
- close() - Method in class alluxio.proxy.s3.S3AuditContext
-
- CLOSE - Static variable in class alluxio.proxy.StreamsRestServiceHandler
-
- close(Integer) - Method in class alluxio.proxy.StreamsRestServiceHandler
-
- compare(URIStatus, URIStatus) - Method in class alluxio.proxy.s3.S3RestUtils.URIStatusNameComparator
-
- CompleteMultipartUploadHandler - Class in alluxio.proxy.s3
-
A handler process multipart upload complete response.
- CompleteMultipartUploadHandler(FileSystem, String) - Constructor for class alluxio.proxy.s3.CompleteMultipartUploadHandler
-
- CompleteMultipartUploadHandler.CompleteMultipartUploadTask - Class in alluxio.proxy.s3
-
Complete Multipart upload Task.
- CompleteMultipartUploadRequest - Class in alluxio.proxy.s3
-
Implementation of CompleteMultipartUploadRequest according to
https://docs.aws.amazon.com/AmazonS3/latest/API/API_ListMultipartUploads.html.
- CompleteMultipartUploadRequest() - Constructor for class alluxio.proxy.s3.CompleteMultipartUploadRequest
-
- CompleteMultipartUploadRequest(List<CompleteMultipartUploadRequest.Part>) - Constructor for class alluxio.proxy.s3.CompleteMultipartUploadRequest
-
- CompleteMultipartUploadRequest(List<CompleteMultipartUploadRequest.Part>, boolean) - Constructor for class alluxio.proxy.s3.CompleteMultipartUploadRequest
-
- CompleteMultipartUploadRequest.Part - Class in alluxio.proxy.s3
-
The Part POJO.
- CompleteMultipartUploadResult - Class in alluxio.proxy.s3
-
Result returned after requests for completing a multipart upload.
- CompleteMultipartUploadResult() - Constructor for class alluxio.proxy.s3.CompleteMultipartUploadResult
-
- CompleteMultipartUploadResult(String, String, String, String) - Constructor for class alluxio.proxy.s3.CompleteMultipartUploadResult
-
- CompleteMultipartUploadResult(String, String) - Constructor for class alluxio.proxy.s3.CompleteMultipartUploadResult
-
- CompleteMultipartUploadTask(FileSystem, FileSystem, String, String, String, String) - Constructor for class alluxio.proxy.s3.CompleteMultipartUploadHandler.CompleteMultipartUploadTask
-
- CompleteMultipartUploadTask(S3Handler, S3BaseTask.OpType) - Constructor for class alluxio.proxy.s3.S3ObjectTask.CompleteMultipartUploadTask
-
Create a CompleteMultipartUploadTask.
- Content(String, String, String) - Constructor for class alluxio.proxy.s3.ListBucketResult.Content
-
- Content(String, String, String, boolean) - Constructor for class alluxio.proxy.s3.ListBucketResult.Content
-
- CONTENT_TYPE_XATTR_KEY - Static variable in class alluxio.proxy.s3.S3Constants
-
- continueTask() - Method in class alluxio.proxy.s3.S3BaseTask
-
Run core S3 API logic from different S3 task.
- continueTask() - Method in class alluxio.proxy.s3.S3BucketTask
-
- continueTask() - Method in class alluxio.proxy.s3.S3ObjectTask.CompleteMultipartUploadTask
-
- continueTask() - Method in class alluxio.proxy.s3.S3ObjectTask
-
- CopyObjectResult - Class in alluxio.proxy.s3
-
Result of an S3 Copy.
- CopyObjectResult(String, long) - Constructor for class alluxio.proxy.s3.CopyObjectResult
-
- CopyPartResult - Class in alluxio.proxy.s3
-
Result of an S3 UploadPartCopy.
- CopyPartResult(String) - Constructor for class alluxio.proxy.s3.CopyPartResult
-
- create() - Static method in class alluxio.proxy.ProxyProcess.Factory
-
- create(AlluxioConfiguration) - Static method in class alluxio.proxy.s3.auth.Authenticator.Factory
-
- create(FileInStream, long, S3RangeSpec) - Static method in class alluxio.proxy.s3.RangeFileInStream.Factory
-
- create(S3Handler) - Static method in class alluxio.proxy.s3.S3BucketTask.Factory
-
Marshall the request and create corresponding bucket level S3 task.
- create(S3Handler) - Static method in class alluxio.proxy.s3.S3ObjectTask.Factory
-
Marshall the request and create corresponding object level S3 task.
- create(String) - Static method in class alluxio.proxy.s3.S3RangeSpec.Factory
-
- create(String) - Static method in class alluxio.proxy.s3.signature.AwsCredential
-
Parse credential value.
- CREATE_DIRECTORY - Static variable in class alluxio.proxy.PathsRestServiceHandler
-
- CREATE_FILE - Static variable in class alluxio.proxy.PathsRestServiceHandler
-
- createAuditContext(String, String, String, String) - Method in class alluxio.proxy.s3.S3Handler
-
- createBucket(String, String, String, String, InputStream) - Method in class alluxio.proxy.s3.S3RestServiceHandler
-
Creates a bucket, or puts bucket tags on an existing bucket.
- createDirectory(String, CreateDirectoryPOptions) - Method in class alluxio.proxy.PathsRestServiceHandler
-
- createErrorResponse(Throwable, String) - Static method in class alluxio.proxy.s3.S3ErrorResponse
-
Creates an error response using the given exception.
- createFile(String, CreateFilePOptions) - Method in class alluxio.proxy.PathsRestServiceHandler
-
- createFileSystemForUser(String, FileSystem) - Static method in class alluxio.proxy.s3.S3RestUtils
-
- createHandler(String, HttpServletRequest, HttpServletResponse) - Static method in class alluxio.proxy.s3.S3Handler
-
Create a S3Handler based on the incoming Request.
- createObjectOrUploadPart(String, String, String, String, S3Constants.Directive, String, S3Constants.Directive, String, String, String, String, Integer, String, String, String, InputStream) - Method in class alluxio.proxy.s3.S3RestServiceHandler
-
Uploads an object or part of an object in multipart upload.
- createRateLimiter(long) - Static method in class alluxio.proxy.s3.S3RestUtils
-
Create a rate limiter for given rate.
- createScope() - Method in class alluxio.proxy.s3.signature.AwsCredential
-
- createSignatureBase(SignatureInfo, ContainerRequestContext) - Static method in class alluxio.proxy.s3.signature.StringToSignProducer
-
Convert signature info to strToSign.
- createSignatureBase(SignatureInfo, HttpServletRequest) - Static method in class alluxio.proxy.s3.signature.StringToSignProducer
-
Convert signature info to strToSign.
- createSignatureBase(SignatureInfo, String, String, String, Map<String, String>, Map<String, String>) - Static method in class alluxio.proxy.s3.signature.StringToSignProducer
-
Convert request info to strToSign.
- GET_INFO - Static variable in class alluxio.proxy.AlluxioProxyRestServiceHandler
-
- GET_STATUS - Static variable in class alluxio.proxy.PathsRestServiceHandler
-
- getAccessID() - Method in class alluxio.proxy.s3.auth.AwsAuthInfo
-
- getAccessKeyID() - Method in class alluxio.proxy.s3.signature.AwsCredential
-
- getAlgorithm() - Method in class alluxio.proxy.s3.signature.SignatureInfo
-
- getAuthInfo() - Method in class alluxio.proxy.s3.signature.AwsSignatureProcessor
-
Convert SignatureInfo to AwsAuthInfo.
- getAwsAccessId() - Method in class alluxio.proxy.s3.signature.SignatureInfo
-
- getAwsRegion() - Method in class alluxio.proxy.s3.signature.AwsCredential
-
- getAwsRequest() - Method in class alluxio.proxy.s3.signature.AwsCredential
-
- getAwsService() - Method in class alluxio.proxy.s3.signature.AwsCredential
-
- getBucket() - Method in class alluxio.proxy.s3.CompleteMultipartUploadResult
-
- getBucket() - Method in class alluxio.proxy.s3.InitiateMultipartUploadResult
-
- getBucket() - Method in class alluxio.proxy.s3.ListMultipartUploadsResult
-
- getBucket() - Method in class alluxio.proxy.s3.ListPartsResult
-
- getBucket() - Method in class alluxio.proxy.s3.S3Handler
-
Get the bucket name of this request.
- getBucket(String, String, String, String, String, Integer, Integer, String, String, String, String, String, String, String, String) - Method in class alluxio.proxy.s3.S3RestServiceHandler
-
Gets a bucket and lists all the objects or bucket tags in it.
- getBuckets() - Method in class alluxio.proxy.s3.ListAllMyBucketsResult
-
- getCode() - Method in class alluxio.proxy.s3.CompleteMultipartUploadResult
-
- getCode() - Method in class alluxio.proxy.s3.S3Error
-
- getCode() - Method in class alluxio.proxy.s3.S3ErrorCode
-
- getCommonPrefixes() - Method in class alluxio.proxy.s3.ListBucketResult
-
- getContents() - Method in class alluxio.proxy.s3.ListBucketResult
-
- getContinuationToken() - Method in class alluxio.proxy.s3.ListBucketOptions
-
- getContinuationToken() - Method in class alluxio.proxy.s3.ListBucketResult
-
- getCreationDate() - Method in class alluxio.proxy.s3.ListAllMyBucketsResult.Bucket
-
- getCredentialScope() - Method in class alluxio.proxy.s3.signature.SignatureInfo
-
- getDate() - Method in class alluxio.proxy.s3.signature.AwsCredential
-
- getDate() - Method in class alluxio.proxy.s3.signature.SignatureInfo
-
- getDateTime() - Method in class alluxio.proxy.s3.signature.SignatureInfo
-
- getDeleted() - Method in class alluxio.proxy.s3.DeleteObjectsResult
-
- getDelimiter() - Method in class alluxio.proxy.s3.ListBucketOptions
-
- getDelimiter() - Method in class alluxio.proxy.s3.ListBucketResult
-
- getDescription() - Method in class alluxio.proxy.s3.S3ErrorCode
-
- getEncodingType() - Method in class alluxio.proxy.s3.ListBucketOptions
-
- getEncodingType() - Method in class alluxio.proxy.s3.ListBucketResult
-
- getEntityTag(URIStatus) - Static method in class alluxio.proxy.s3.S3RestUtils
-
This helper method is used to get the ETag xAttr on an object.
- getErrorCode() - Method in exception alluxio.proxy.s3.S3Exception
-
- getErrored() - Method in class alluxio.proxy.s3.DeleteObjectsResult
-
- getETag() - Method in class alluxio.proxy.s3.CompleteMultipartUploadRequest.Part
-
- getETag() - Method in class alluxio.proxy.s3.CompleteMultipartUploadResult
-
- getEtag() - Method in class alluxio.proxy.s3.CopyObjectResult
-
- getEtag() - Method in class alluxio.proxy.s3.CopyPartResult
-
- getETag() - Method in class alluxio.proxy.s3.ListPartsResult.Part
-
- getHeader(String) - Method in class alluxio.proxy.s3.S3Handler
-
get specified HTTP header value of this request.
- getHeaderOrDefault(String, String) - Method in class alluxio.proxy.s3.S3Handler
-
get specified HTTP header with a default if not exist.
- getHTTPVerb() - Method in class alluxio.proxy.s3.S3Handler
-
get HTTP verb of this request.
- getInfo(Boolean) - Method in class alluxio.proxy.AlluxioProxyRestServiceHandler
-
- getInitiated() - Method in class alluxio.proxy.s3.ListMultipartUploadsResult.Upload
-
- getInputStream() - Method in class alluxio.proxy.s3.S3Handler
-
retrieve inputstream from incoming request.
- getInstance() - Static method in class alluxio.proxy.s3.MultipartUploadCleaner
-
- getInStream(Integer) - Method in class alluxio.StreamCache
-
- getKey() - Method in class alluxio.proxy.s3.CompleteMultipartUploadResult
-
- getKey() - Method in class alluxio.proxy.s3.InitiateMultipartUploadResult
-
- getKey() - Method in class alluxio.proxy.s3.ListBucketResult.Content
-
- getKey() - Method in class alluxio.proxy.s3.ListMultipartUploadsResult.Upload
-
- getKey() - Method in class alluxio.proxy.s3.ListPartsResult
-
- getKeyCount() - Method in class alluxio.proxy.s3.ListBucketResult
-
- getLastModified() - Method in class alluxio.proxy.s3.CopyObjectResult
-
- getLastModified() - Method in class alluxio.proxy.s3.ListBucketResult.Content
-
- getLastModified() - Method in class alluxio.proxy.s3.ListPartsResult.Part
-
- getLength(long) - Method in class alluxio.proxy.s3.S3RangeSpec
-
Get real length of object.
- getListType() - Method in class alluxio.proxy.s3.ListBucketOptions
-
- getLocation() - Method in class alluxio.proxy.s3.CompleteMultipartUploadResult
-
- getMarker() - Method in class alluxio.proxy.s3.ListBucketOptions
-
- getMarker() - Method in class alluxio.proxy.s3.ListBucketResult
-
- getMaxKeys() - Method in class alluxio.proxy.s3.ListBucketOptions
-
- getMaxKeys() - Method in class alluxio.proxy.s3.ListBucketResult
-
- getMessage() - Method in class alluxio.proxy.s3.CompleteMultipartUploadResult
-
- getMessage() - Method in class alluxio.proxy.s3.S3Error
-
- getMetaFS() - Method in class alluxio.proxy.s3.S3Handler
-
Get system user FileSystem object.
- getMultipartMetaFilepathForUploadId(String) - Static method in class alluxio.proxy.s3.S3RestUtils
-
- getMultipartTemporaryDirForObject(String, String, String) - Static method in class alluxio.proxy.s3.S3RestUtils
-
- getName() - Method in class alluxio.proxy.s3.ListAllMyBucketsResult.Bucket
-
- getName() - Method in class alluxio.proxy.s3.ListBucketResult
-
- getNextContinuationToken() - Method in class alluxio.proxy.s3.ListBucketResult
-
- getNextMarker() - Method in class alluxio.proxy.s3.ListBucketResult
-
- getObject() - Method in class alluxio.proxy.s3.S3Handler
-
Get the object name of this request.
- getObjectMetadata(String, String) - Method in class alluxio.proxy.s3.S3RestServiceHandler
-
Retrieves an object's metadata.
- getObjectOrListParts(String, String, String, String, String, String) - Method in class alluxio.proxy.s3.S3RestServiceHandler
-
Downloads an object or list parts of the object in multipart upload.
- getObjectTaskResource() - Method in class alluxio.proxy.s3.S3ObjectTask
-
Concatenate bucket and object to make a full path.
- getOffset(long) - Method in class alluxio.proxy.s3.S3RangeSpec
-
Get real offset of object.
- getOPType() - Method in class alluxio.proxy.s3.S3BaseTask
-
Return the OpType (S3 API enum).
- getOutStream(Integer) - Method in class alluxio.StreamCache
-
- getPartNumber() - Method in class alluxio.proxy.s3.CompleteMultipartUploadRequest.Part
-
- getPartNumber() - Method in class alluxio.proxy.s3.ListPartsResult.Part
-
- getParts() - Method in class alluxio.proxy.s3.CompleteMultipartUploadRequest
-
- getParts() - Method in class alluxio.proxy.s3.ListPartsResult
-
- getPrefix() - Method in class alluxio.proxy.s3.ListBucketOptions
-
- getPrefix() - Method in class alluxio.proxy.s3.ListBucketResult.CommonPrefix
-
- getPrefix() - Method in class alluxio.proxy.s3.ListBucketResult
-
- getQueryParameter(String) - Method in class alluxio.proxy.s3.S3Handler
-
retrieve given query parameter value.
- getQuiet() - Method in class alluxio.proxy.s3.DeleteObjectsRequest
-
- getRealRange(long) - Method in class alluxio.proxy.s3.S3RangeSpec
-
Get real range of response.
- getRemoteServiceType() - Method in class alluxio.proxy.RetryHandlingMetaMasterProxyClient
-
- getRequestId() - Method in class alluxio.proxy.s3.S3Error
-
- getResource() - Method in class alluxio.proxy.s3.S3Error
-
- getResource() - Method in exception alluxio.proxy.s3.S3Exception
-
- getRetryDelay() - Method in class alluxio.proxy.s3.MultipartUploadCleaner
-
Get retry delay.
- getS3Task() - Method in class alluxio.proxy.s3.S3Handler
-
get S3Task of this S3Handler.
- getS3WriteType() - Static method in class alluxio.proxy.s3.S3RestUtils
-
- getServiceName() - Method in class alluxio.proxy.RetryHandlingMetaMasterProxyClient
-
- getServiceVersion() - Method in class alluxio.proxy.RetryHandlingMetaMasterProxyClient
-
- getServletContext() - Method in class alluxio.proxy.s3.S3Handler
-
get ServletContext from current http conversation.
- getServletRequest() - Method in class alluxio.proxy.s3.S3Handler
-
get HttpServletRequest of this request.
- getServletResponse() - Method in class alluxio.proxy.s3.S3Handler
-
get HttpServletResponse of this request.
- getSignature() - Method in class alluxio.proxy.s3.auth.AwsAuthInfo
-
- getSignature() - Method in class alluxio.proxy.s3.signature.SignatureInfo
-
- getSignedHeaders() - Method in class alluxio.proxy.s3.signature.SignatureInfo
-
- getSize() - Method in class alluxio.proxy.s3.ListBucketResult.Content
-
- getSize() - Method in class alluxio.proxy.s3.ListPartsResult.Part
-
- getStartAfter() - Method in class alluxio.proxy.s3.ListBucketOptions
-
- getStartAfter() - Method in class alluxio.proxy.s3.ListBucketResult
-
- getStartTimeMs() - Method in class alluxio.proxy.AlluxioProxyProcess
-
- getStartTimeMs() - Method in interface alluxio.proxy.ProxyProcess
-
- getStatus(String, GetStatusPOptions) - Method in class alluxio.proxy.PathsRestServiceHandler
-
- getStatus() - Method in class alluxio.proxy.s3.S3ErrorCode
-
- getStopwatch() - Method in class alluxio.proxy.s3.S3Handler
-
Get Stopwatch object used for recording this request's latency.
- getStorageClass() - Method in class alluxio.proxy.s3.ListPartsResult
-
- getStringTosSign() - Method in class alluxio.proxy.s3.auth.AwsAuthInfo
-
- getTagMap() - Method in class alluxio.proxy.s3.TaggingData
-
Returns the Map object containing the contents of
the TagSet.
- getToDelete() - Method in class alluxio.proxy.s3.DeleteObjectsRequest
-
- getUploadId() - Method in class alluxio.proxy.s3.InitiateMultipartUploadResult
-
- getUploadId() - Method in class alluxio.proxy.s3.ListMultipartUploadsResult.Upload
-
- getUploadId() - Method in class alluxio.proxy.s3.ListPartsResult
-
- getUploads() - Method in class alluxio.proxy.s3.ListMultipartUploadsResult
-
- getUptimeMs() - Method in class alluxio.proxy.AlluxioProxyProcess
-
- getUptimeMs() - Method in interface alluxio.proxy.ProxyProcess
-
- getUser() - Method in class alluxio.proxy.s3.S3Handler
-
Get the user name of this request.
- getUser(String, ContainerRequestContext) - Static method in class alluxio.proxy.s3.S3RestUtils
-
Get username from header info.
- getUser(String, HttpServletRequest) - Static method in class alluxio.proxy.s3.S3RestUtils
-
Get username from header info from HttpServletRequest.
- getUserFromAuthorization(String, AlluxioConfiguration) - Static method in class alluxio.proxy.s3.S3RestUtils
-
Gets the user from the authorization header string for AWS Signature Version 4.
- getVersion() - Method in class alluxio.proxy.s3.signature.SignatureInfo
-
- getWebLocalPort() - Method in class alluxio.proxy.AlluxioProxyProcess
-
- getWebLocalPort() - Method in interface alluxio.proxy.ProxyProcess
-
- GLOBAL_RATE_LIMITER_SERVLET_RESOURCE_KEY - Static variable in class alluxio.web.ProxyWebServer
-
- parseCompleteMultipartUploadRequest(String) - Method in class alluxio.proxy.s3.CompleteMultipartUploadHandler.CompleteMultipartUploadTask
-
Parse xml http body for CompleteMultipartUploadRequest.
- parseCompleteMultipartUploadRequest(String) - Method in class alluxio.proxy.s3.S3ObjectTask.CompleteMultipartUploadTask
-
Parse xml http body for CompleteMultipartUploadRequest.
- parsePath(String) - Static method in class alluxio.proxy.s3.S3RestUtils
-
Format bucket path.
- parseSignature() - Method in class alluxio.proxy.s3.signature.AwsSignatureProcessor
-
Extract signature info from request.
- parseSignature(String) - Static method in class alluxio.proxy.s3.signature.utils.AwsAuthV2HeaderParserUtils
-
Function to parse signature.
- parseSignature(String, String) - Static method in class alluxio.proxy.s3.signature.utils.AwsAuthV4HeaderParserUtils
-
Function to parse signature.
- parseSignature(Map<String, String>) - Static method in class alluxio.proxy.s3.signature.utils.AwsAuthV4QueryParserUtils
-
Function to parse signature.
- Part() - Constructor for class alluxio.proxy.s3.CompleteMultipartUploadRequest.Part
-
- Part(String, int) - Constructor for class alluxio.proxy.s3.CompleteMultipartUploadRequest.Part
-
- Part() - Constructor for class alluxio.proxy.s3.ListPartsResult.Part
-
- PassAllAuthenticator - Class in alluxio.proxy.s3.auth
-
- PassAllAuthenticator() - Constructor for class alluxio.proxy.s3.auth.PassAllAuthenticator
-
- PATH_PARAM - Static variable in class alluxio.proxy.PathsRestServiceHandler
-
- PathsRestServiceHandler - Class in alluxio.proxy
-
This class is a REST handler for path resources.
- PathsRestServiceHandler(ServletContext) - Constructor for class alluxio.proxy.PathsRestServiceHandler
-
- populateContentTypeInXAttr(Map<String, ByteString>, String) - Static method in class alluxio.proxy.s3.S3RestUtils
-
Populate xattr with content type info from header.
- populateTaggingInXAttr(Map<String, ByteString>, String, S3AuditContext, String) - Static method in class alluxio.proxy.s3.S3RestUtils
-
Populate xattr map with tagging info from tagging header.
- postBucket(String, String, int, InputStream) - Method in class alluxio.proxy.s3.S3RestServiceHandler
-
Currently implements the DeleteObjects request type if the query parameter "delete" exists.
- PRECONDITION_FAILED - Static variable in class alluxio.proxy.s3.S3ErrorCode.Name
-
- PRECONDITION_FAILED - Static variable in class alluxio.proxy.s3.S3ErrorCode
-
- prepareForCreateTempFile(URIStatus) - Method in class alluxio.proxy.s3.CompleteMultipartUploadHandler.CompleteMultipartUploadTask
-
Prepare CreateFilePOptions for create temp multipart upload file.
- prepareForCreateTempFile(URIStatus) - Method in class alluxio.proxy.s3.S3ObjectTask.CompleteMultipartUploadTask
-
Prepare CreateFilePOptions for create temp multipart upload file.
- printCollection(String, Collection<? extends Object>) - Method in class alluxio.proxy.s3.S3Handler
-
Utility function to dump a collection into a string.
- printMap(String, Map<? extends Object, ? extends Object>) - Method in class alluxio.proxy.s3.S3Handler
-
Utility function to dump a map into a string.
- processResponse(HttpServletResponse, Response) - Static method in class alluxio.proxy.s3.S3Handler
-
Process the response returned from S3Task core logic to write to downstream.
- PROXY_S3_V2_HEAVY_POOL - Static variable in class alluxio.proxy.s3.S3RequestServlet
-
- PROXY_S3_V2_LIGHT_POOL - Static variable in class alluxio.proxy.s3.S3RequestServlet
-
- PROXY_V2_ASYNC_ENABLED - Static variable in class alluxio.proxy.s3.S3RequestServlet
-
- proxyHeartbeat() - Method in class alluxio.proxy.RetryHandlingMetaMasterProxyClient
-
Sends a heartbeat to the primary master.
- ProxyMasterSync - Class in alluxio.proxy
-
The Proxy will maintain a stateless heartbeat with the primary master.
- ProxyMasterSync(Address, MasterClientContext, long) - Constructor for class alluxio.proxy.ProxyMasterSync
-
- ProxyProcess - Interface in alluxio.proxy
-
A proxy in the Alluxio system.
- ProxyProcess.Factory - Class in alluxio.proxy
-
- ProxyWebServer - Class in alluxio.web
-
The Alluxio proxy web server.
- ProxyWebServer(String, InetSocketAddress, ProxyProcess) - Constructor for class alluxio.web.ProxyWebServer
-
- put(FileInStream) - Method in class alluxio.StreamCache
-
- put(FileOutStream) - Method in class alluxio.StreamCache
-
- S3_ACCEPT_RANGES_HEADER - Static variable in class alluxio.proxy.s3.S3Constants
-
- S3_ACCEPT_RANGES_VALUE - Static variable in class alluxio.proxy.s3.S3Constants
-
- S3_ACL_HEADER - Static variable in class alluxio.proxy.s3.S3Constants
-
- S3_CONTENT_LENGTH_HEADER - Static variable in class alluxio.proxy.s3.S3Constants
-
- S3_CONTENT_RANGE_HEADER - Static variable in class alluxio.proxy.s3.S3Constants
-
- S3_CONTENT_TYPE_HEADER - Static variable in class alluxio.proxy.s3.S3Constants
-
- S3_COPY_SOURCE_HEADER - Static variable in class alluxio.proxy.s3.S3Constants
-
- S3_COPY_SOURCE_RANGE - Static variable in class alluxio.proxy.s3.S3Constants
-
- S3_DATE_FORMAT_REGEXP - Static variable in class alluxio.proxy.s3.S3Constants
-
- S3_ETAG_HEADER - Static variable in class alluxio.proxy.s3.S3Constants
-
- S3_HANDLER_ATTRIBUTE - Static variable in class alluxio.web.ProxyWebServer
-
- S3_METADATA_DIRECTIVE_HEADER - Static variable in class alluxio.proxy.s3.S3Constants
-
- S3_METADATA_ROOT_DIR - Static variable in class alluxio.proxy.s3.S3Constants
-
- S3_METADATA_UPLOADS_DIR - Static variable in class alluxio.proxy.s3.S3Constants
-
- S3_MULTIPART_PART_PREFIX - Static variable in class alluxio.proxy.s3.S3Constants
-
- S3_SIGN_ALGORITHM - Static variable in class alluxio.proxy.s3.S3Constants
-
- S3_SIGN_CONTENT_SHA256 - Static variable in class alluxio.proxy.s3.S3Constants
-
- S3_SIGN_CREDENTIAL - Static variable in class alluxio.proxy.s3.S3Constants
-
- S3_SIGN_DATE - Static variable in class alluxio.proxy.s3.S3Constants
-
- S3_SIGN_EXPIRES - Static variable in class alluxio.proxy.s3.S3Constants
-
- S3_SIGN_SIGNATURE - Static variable in class alluxio.proxy.s3.S3Constants
-
- S3_SIGN_SIGNED_HEADER - Static variable in class alluxio.proxy.s3.S3Constants
-
- S3_STANDARD_STORAGE_CLASS - Static variable in class alluxio.proxy.s3.S3Constants
-
- S3_TAGGING_COUNT_HEADER - Static variable in class alluxio.proxy.s3.S3Constants
-
- S3_TAGGING_DIRECTIVE_HEADER - Static variable in class alluxio.proxy.s3.S3Constants
-
- S3_TAGGING_HEADER - Static variable in class alluxio.proxy.s3.S3Constants
-
- S3_V2_SERVICE_PATH_PREFIX - Static variable in class alluxio.proxy.s3.S3RequestServlet
-
- S3AuditContext - Class in alluxio.proxy.s3
-
An audit context for s3 rest service.
- S3AuditContext(AsyncUserAccessAuditLogWriter) - Constructor for class alluxio.proxy.s3.S3AuditContext
-
- S3AuthenticationFilter - Class in alluxio.proxy.s3
-
Authentication filter for S3 API.
- S3AuthenticationFilter() - Constructor for class alluxio.proxy.s3.S3AuthenticationFilter
-
- S3BaseTask - Class in alluxio.proxy.s3
-
S3 Abstract Base task for handling S3 API logic.
- S3BaseTask(S3Handler, S3BaseTask.OpType) - Constructor for class alluxio.proxy.s3.S3BaseTask
-
Instantiate a S3BaseTask.
- S3BaseTask.OpTag - Enum in alluxio.proxy.s3
-
Enum for tagging the http request to target for
different threadpools for handling.
- S3BaseTask.OpType - Enum in alluxio.proxy.s3
-
Enum indicating name of S3 API handling per http request.
- S3BucketTask - Class in alluxio.proxy.s3
-
S3 Tasks to handle bucket level or global level request.
- S3BucketTask(S3Handler, S3BaseTask.OpType) - Constructor for class alluxio.proxy.s3.S3BucketTask
-
- S3BucketTask.Factory - Class in alluxio.proxy.s3
-
Factory for getting a S3BucketTask type task.
- S3Constants - Class in alluxio.proxy.s3
-
Constants for S3 northbound API.
- S3Constants.Directive - Enum in alluxio.proxy.s3
-
Directive specifies whether metadata/tag-set are copied from the source object
or replaced with metadata/tag-set provided in the request.
- S3Error - Class in alluxio.proxy.s3
-
Error response defined in http://docs.aws.amazon.com/AmazonS3/latest/API/ErrorResponses.html.
- S3Error() - Constructor for class alluxio.proxy.s3.S3Error
-
- S3Error(String, S3ErrorCode) - Constructor for class alluxio.proxy.s3.S3Error
-
Creates a new Error.
- S3ErrorCode - Class in alluxio.proxy.s3
-
Error codes defined in http://docs.aws.amazon.com/AmazonS3/latest/API/ErrorResponses.html with
API version 2006-03-01.
- S3ErrorCode(String, String, Response.Status) - Constructor for class alluxio.proxy.s3.S3ErrorCode
-
- S3ErrorCode.Name - Class in alluxio.proxy.s3
-
- S3ErrorResponse - Class in alluxio.proxy.s3
-
Utilities for creating HTTP Responses for the S3 API.
- S3ErrorResponse() - Constructor for class alluxio.proxy.s3.S3ErrorResponse
-
- S3Exception - Exception in alluxio.proxy.s3
-
An exception thrown during processing S3 REST requests.
- S3Exception(S3ErrorCode) - Constructor for exception alluxio.proxy.s3.S3Exception
-
- S3Exception(String, S3ErrorCode) - Constructor for exception alluxio.proxy.s3.S3Exception
-
- S3Exception(Exception, String, S3ErrorCode) - Constructor for exception alluxio.proxy.s3.S3Exception
-
- S3Exception(String, String, S3ErrorCode) - Constructor for exception alluxio.proxy.s3.S3Exception
-
- S3Handler - Class in alluxio.proxy.s3
-
- S3Handler(String, String, HttpServletRequest, HttpServletResponse) - Constructor for class alluxio.proxy.s3.S3Handler
-
S3Handler Constructor.
- S3ObjectTask - Class in alluxio.proxy.s3
-
S3 Tasks to handle object level request.
- S3ObjectTask(S3Handler, S3BaseTask.OpType) - Constructor for class alluxio.proxy.s3.S3ObjectTask
-
- S3ObjectTask.CompleteMultipartUploadTask - Class in alluxio.proxy.s3
-
CompleteMultipartUploadTask.
- S3ObjectTask.Factory - Class in alluxio.proxy.s3
-
Factory for getting a S3ObjectTask.
- S3RangeSpec - Class in alluxio.proxy.s3
-
This class is Range Spec for Amazon S3 API.
- S3RangeSpec(boolean) - Constructor for class alluxio.proxy.s3.S3RangeSpec
-
- S3RangeSpec(long, long) - Constructor for class alluxio.proxy.s3.S3RangeSpec
-
- S3RangeSpec.Factory - Class in alluxio.proxy.s3
-
- S3RequestServlet - Class in alluxio.proxy.s3
-
New architecture Request Servlet for handling s3 requests
in replacement of JAX-RS.
- S3RequestServlet() - Constructor for class alluxio.proxy.s3.S3RequestServlet
-
- S3RestExceptionMapper - Class in alluxio.proxy.s3
-
An exception mapper for REST PROXY to convert inner exception to HTTP Response.
- S3RestExceptionMapper() - Constructor for class alluxio.proxy.s3.S3RestExceptionMapper
-
- S3RestServiceHandler - Class in alluxio.proxy.s3
-
This class is a REST handler for Amazon S3 API.
- S3RestServiceHandler(ServletContext) - Constructor for class alluxio.proxy.s3.S3RestServiceHandler
-
- S3RestUtils - Class in alluxio.proxy.s3
-
Utilities for handling S3 REST calls.
- S3RestUtils.RestCallable<T> - Interface in alluxio.proxy.s3
-
An interface representing a callable.
- S3RestUtils.URIStatusNameComparator - Class in alluxio.proxy.s3
-
Comparator based on uri nameļ¼ treat uri name as a Long number.
- serialize(TaggingData) - Static method in class alluxio.proxy.s3.TaggingData
-
Serializes the object as an XML (bytes).
- SERVER_CONFIGURATION_RESOURCE_KEY - Static variable in class alluxio.web.ProxyWebServer
-
- serveRequest(S3Handler) - Method in class alluxio.proxy.s3.S3RequestServlet
-
Core place to call S3 task's core API logic handling
function w/o exception handling.
- service(HttpServletRequest, HttpServletResponse) - Method in class alluxio.proxy.s3.S3RequestServlet
-
Implementation to serve the HttpServletRequest and returns HttpServletResponse.
- SERVICE_PREFIX - Static variable in class alluxio.proxy.AlluxioProxyRestServiceHandler
-
- SERVICE_PREFIX - Static variable in class alluxio.proxy.PathsRestServiceHandler
-
- SERVICE_PREFIX - Static variable in class alluxio.proxy.s3.S3RequestServlet
-
- SERVICE_PREFIX - Static variable in class alluxio.proxy.s3.S3RestServiceHandler
-
- SERVICE_PREFIX - Static variable in class alluxio.proxy.StreamsRestServiceHandler
-
- SET_ATTRIBUTE - Static variable in class alluxio.proxy.PathsRestServiceHandler
-
- setAllowed(boolean) - Method in class alluxio.proxy.s3.S3AuditContext
-
- setAttribute(String, SetAttributePOptions) - Method in class alluxio.proxy.PathsRestServiceHandler
-
- setBucket(String) - Method in class alluxio.proxy.s3.CompleteMultipartUploadResult
-
- setBucket(String) - Method in class alluxio.proxy.s3.InitiateMultipartUploadResult
-
- setBucket(String) - Method in class alluxio.proxy.s3.ListMultipartUploadsResult
-
- setBucket(String) - Method in class alluxio.proxy.s3.ListPartsResult
-
- setBucket(String) - Method in class alluxio.proxy.s3.S3AuditContext
-
Sets mBucket field.
- setCode(String) - Method in class alluxio.proxy.s3.CompleteMultipartUploadResult
-
- setCode(String) - Method in class alluxio.proxy.s3.S3Error
-
- setCommand(String) - Method in class alluxio.proxy.s3.S3AuditContext
-
Sets mCommand field.
- setContinuationToken(String) - Method in class alluxio.proxy.s3.ListBucketOptions
-
- setCreationTimeNs(long) - Method in class alluxio.proxy.s3.S3AuditContext
-
Sets mCreationTimeNs field.
- setDeleted(List<DeleteObjectsResult.DeletedObject>) - Method in class alluxio.proxy.s3.DeleteObjectsResult
-
Sets the set of deleted objects.
- setDeleteObject(List<DeleteObjectsRequest.DeleteObject>) - Method in class alluxio.proxy.s3.DeleteObjectsRequest
-
Set of items to delete.
- setDelimiter(String) - Method in class alluxio.proxy.s3.ListBucketOptions
-
- setEncodingType(String) - Method in class alluxio.proxy.s3.ListBucketOptions
-
- setEntityTag(FileSystem, AlluxioURI, String) - Static method in class alluxio.proxy.s3.S3RestUtils
-
This helper method is used to set the ETag xAttr on an object.
- setErrored(List<DeleteObjectsResult.ErrorObject>) - Method in class alluxio.proxy.s3.DeleteObjectsResult
-
Sets the set of errored objects in the response.
- setETag(String) - Method in class alluxio.proxy.s3.CompleteMultipartUploadResult
-
- setETag(String) - Method in class alluxio.proxy.s3.ListPartsResult.Part
-
- setInitiated(String) - Method in class alluxio.proxy.s3.ListMultipartUploadsResult.Upload
-
- setIp(String) - Method in class alluxio.proxy.s3.S3AuditContext
-
Sets mIp field.
- setIsTruncated(boolean) - Method in class alluxio.proxy.s3.ListPartsResult
-
- setKey(String) - Method in class alluxio.proxy.s3.CompleteMultipartUploadRequest.Part
-
- setKey(int) - Method in class alluxio.proxy.s3.CompleteMultipartUploadRequest.Part
-
- setKey(String) - Method in class alluxio.proxy.s3.CompleteMultipartUploadResult
-
- setKey(String) - Method in class alluxio.proxy.s3.InitiateMultipartUploadResult
-
- setKey(String) - Method in class alluxio.proxy.s3.ListMultipartUploadsResult.Upload
-
- setKey(String) - Method in class alluxio.proxy.s3.ListPartsResult
-
- setLastModified(String) - Method in class alluxio.proxy.s3.ListPartsResult.Part
-
- setListType(Integer) - Method in class alluxio.proxy.s3.ListBucketOptions
-
- setLocation(String) - Method in class alluxio.proxy.s3.CompleteMultipartUploadResult
-
- setMarker(String) - Method in class alluxio.proxy.s3.ListBucketOptions
-
- setMaxKeys(int) - Method in class alluxio.proxy.s3.ListBucketOptions
-
- setMessage(String) - Method in class alluxio.proxy.s3.CompleteMultipartUploadResult
-
- setMessage(String) - Method in class alluxio.proxy.s3.S3Error
-
- setObject(String) - Method in class alluxio.proxy.s3.S3AuditContext
-
Sets mObject field.
- setPartNumber(int) - Method in class alluxio.proxy.s3.ListPartsResult.Part
-
- setParts(List<CompleteMultipartUploadRequest.Part>) - Method in class alluxio.proxy.s3.CompleteMultipartUploadRequest
-
- setParts(List<ListPartsResult.Part>) - Method in class alluxio.proxy.s3.ListPartsResult
-
- setPrefix(String) - Method in class alluxio.proxy.s3.ListBucketOptions
-
- setQuiet(boolean) - Method in class alluxio.proxy.s3.DeleteObjectsRequest
-
sets the quiet parameter.
- setRequestId(String) - Method in class alluxio.proxy.s3.S3Error
-
- setResource(String) - Method in class alluxio.proxy.s3.S3Error
-
- setResource(String) - Method in exception alluxio.proxy.s3.S3Exception
-
- setS3Task(S3BaseTask) - Method in class alluxio.proxy.s3.S3Handler
-
set S3Task for this S3Handler.
- setSize(long) - Method in class alluxio.proxy.s3.ListPartsResult.Part
-
- setStartAfter(String) - Method in class alluxio.proxy.s3.ListBucketOptions
-
- setStopwatch(Stopwatch) - Method in class alluxio.proxy.s3.S3Handler
-
Set the Stopwatch object used for recording this request's latency.
- setStorageClass(String) - Method in class alluxio.proxy.s3.ListPartsResult
-
- setSucceeded(boolean) - Method in class alluxio.proxy.s3.S3AuditContext
-
- setUgi(String) - Method in class alluxio.proxy.s3.S3AuditContext
-
Sets mUgi field.
- setUploadId(String) - Method in class alluxio.proxy.s3.InitiateMultipartUploadResult
-
- setUploadId(String) - Method in class alluxio.proxy.s3.ListMultipartUploadsResult.Upload
-
- setUploadId(String) - Method in class alluxio.proxy.s3.ListPartsResult
-
- setUploads(List<ListMultipartUploadsResult.Upload>) - Method in class alluxio.proxy.s3.ListMultipartUploadsResult
-
- shutdown() - Static method in class alluxio.proxy.s3.MultipartUploadCleaner
-
Shutdown cleaner.
- SignatureInfo - Class in alluxio.proxy.s3.signature
-
Signature and related information.
- SignatureInfo(SignatureInfo.Version, String, String, String, String, String, String, String, boolean) - Constructor for class alluxio.proxy.s3.signature.SignatureInfo
-
- SignatureInfo.Version - Enum in alluxio.proxy.s3.signature
-
Signature version.
- size() - Method in class alluxio.StreamCache
-
- start() - Method in class alluxio.proxy.AlluxioProxyProcess
-
- stop() - Method in class alluxio.proxy.AlluxioProxyProcess
-
- stop() - Method in class alluxio.web.ProxyWebServer
-
- STREAM_CACHE_SERVLET_RESOURCE_KEY - Static variable in class alluxio.web.ProxyWebServer
-
- StreamCache - Class in alluxio
-
Cache for storing file input and output streams.
- StreamCache(long) - Constructor for class alluxio.StreamCache
-
- StreamsRestServiceHandler - Class in alluxio.proxy
-
This class is a REST handler for stream resources.
- StreamsRestServiceHandler(ServletContext) - Constructor for class alluxio.proxy.StreamsRestServiceHandler
-
- StringToSignProducer - Class in alluxio.proxy.s3.signature
-
Stateless utility to create stringToSign, the base of the signature.
- validateDateAndExpires(Map<String, String>) - Static method in class alluxio.proxy.s3.signature.utils.AwsAuthV4QueryParserUtils
-
- validateDateRange(String, String) - Static method in class alluxio.proxy.s3.signature.AwsCredential
-
validate credential info.
- validateParts(CompleteMultipartUploadRequest, String, AlluxioURI) - Method in class alluxio.proxy.s3.CompleteMultipartUploadHandler.CompleteMultipartUploadTask
-
Validate the parts as part of this multipart uplaod request.
- validateParts(CompleteMultipartUploadRequest, String, AlluxioURI) - Method in class alluxio.proxy.s3.S3ObjectTask.CompleteMultipartUploadTask
-
Validate the parts as part of this multipart uplaod request.
- validateRequest(String, String, String) - Static method in class alluxio.proxy.s3.signature.AuthorizationV4Validator
-
Validate request by comparing Signature from request.
- valueOf(String) - Static method in enum alluxio.proxy.s3.S3BaseTask.OpTag
-
Returns the enum constant of this type with the specified name.
- valueOf(String) - Static method in enum alluxio.proxy.s3.S3BaseTask.OpType
-
Returns the enum constant of this type with the specified name.
- valueOf(String) - Static method in enum alluxio.proxy.s3.S3Constants.Directive
-
Returns the enum constant of this type with the specified name.
- valueOf(String) - Static method in enum alluxio.proxy.s3.signature.SignatureInfo.Version
-
Returns the enum constant of this type with the specified name.
- values() - Static method in enum alluxio.proxy.s3.S3BaseTask.OpTag
-
Returns an array containing the constants of this enum type, in
the order they are declared.
- values() - Static method in enum alluxio.proxy.s3.S3BaseTask.OpType
-
Returns an array containing the constants of this enum type, in
the order they are declared.
- values() - Static method in enum alluxio.proxy.s3.S3Constants.Directive
-
Returns an array containing the constants of this enum type, in
the order they are declared.
- values() - Static method in enum alluxio.proxy.s3.signature.SignatureInfo.Version
-
Returns an array containing the constants of this enum type, in
the order they are declared.