alluxio.proxy.s3

Class CompleteMultipartUploadHandler.CompleteMultipartUploadTask

java.lang.Object

alluxio.proxy.s3.CompleteMultipartUploadHandler.CompleteMultipartUploadTask

All Implemented Interfaces:

Callable<CompleteMultipartUploadResult>

Enclosing class:

CompleteMultipartUploadHandler

public class CompleteMultipartUploadHandler.CompleteMultipartUploadTask
extends Object
implements Callable<CompleteMultipartUploadResult>

Complete Multipart upload Task.

Constructor Summary

Constructors

Constructor and Description
CompleteMultipartUploadTask(FileSystem metaFs, FileSystem userFs, String bucket, String object, String uploadId, String body) Creates a new instance of CompleteMultipartUploadHandler.CompleteMultipartUploadTask.

Method Summary

Modifier and Type	Method and Description
CompleteMultipartUploadResult	call()
URIStatus	checkIfComplete(String objectPath) On any exception, check with Master on if the there's an object file.
void	cleanupTempPath(String objTempPath) Cleanup the temp object file for complete multipart upload.
CompleteMultipartUploadRequest	parseCompleteMultipartUploadRequest(String objectPath) Parse xml http body for CompleteMultipartUploadRequest.
CreateFilePOptions	prepareForCreateTempFile(URIStatus metaStatus) Prepare CreateFilePOptions for create temp multipart upload file.
void	removePartsDirAndMPMetaFile(AlluxioURI multipartTemporaryDir) Cleanup the multipart upload temporary folder holding the parts files.
List<URIStatus>	validateParts(CompleteMultipartUploadRequest request, String objectPath, AlluxioURI multipartTemporaryDir) Validate the parts as part of this multipart uplaod request.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

CompleteMultipartUploadTask

public CompleteMultipartUploadTask(FileSystem metaFs,
                                   FileSystem userFs,
                                   String bucket,
                                   String object,
                                   String uploadId,
                                   String body)

Creates a new instance of CompleteMultipartUploadHandler.CompleteMultipartUploadTask.

Parameters:

metaFs - instance of FileSystem - used for metadata operations

userFs - instance of FileSystem - under the scope of a user agent

bucket - bucket name

object - object name

uploadId - multipart upload Id

body - the HTTP request body

Method Detail

call

public CompleteMultipartUploadResult call()
                                   throws S3Exception

Specified by:

call in interface Callable<CompleteMultipartUploadResult>

Throws:

S3Exception

prepareForCreateTempFile

public CreateFilePOptions prepareForCreateTempFile(URIStatus metaStatus)

Prepare CreateFilePOptions for create temp multipart upload file.

Parameters:

metaStatus - multi part upload meta file status

Returns:

CreateFilePOptions

parseCompleteMultipartUploadRequest

public CompleteMultipartUploadRequest parseCompleteMultipartUploadRequest(String objectPath)
                                                                   throws S3Exception

Parse xml http body for CompleteMultipartUploadRequest.

Parameters:

objectPath -

Returns:

CompleteMultipartUploadRequest

Throws:

S3Exception

validateParts

public List<URIStatus> validateParts(CompleteMultipartUploadRequest request,
                                     String objectPath,
                                     AlluxioURI multipartTemporaryDir)
                              throws S3Exception,
                                     IOException,
                                     AlluxioException

Validate the parts as part of this multipart uplaod request.

Parameters:

request -

objectPath -

multipartTemporaryDir -

Returns:

List of status of the part files

Throws:

S3Exception

IOException

AlluxioException

removePartsDirAndMPMetaFile

public void removePartsDirAndMPMetaFile(AlluxioURI multipartTemporaryDir)
                                 throws IOException,
                                        AlluxioException

Cleanup the multipart upload temporary folder holding the parts files. and the meta file for this multipart.

Parameters:

multipartTemporaryDir -

Throws:

IOException

AlluxioException

cleanupTempPath

public void cleanupTempPath(String objTempPath)

Cleanup the temp object file for complete multipart upload.

Parameters:

objTempPath -

checkIfComplete

public URIStatus checkIfComplete(String objectPath)

On any exception, check with Master on if the there's an object file. bearing the same upload id already got completed.

Parameters:

objectPath -

Returns:

the status of the existing object through CompleteMultipartUpload call