alluxio.proxy.s3

Class S3ObjectTask.CompleteMultipartUploadTask

java.lang.Object

alluxio.proxy.s3.S3BaseTask

alluxio.proxy.s3.S3ObjectTask

alluxio.proxy.s3.S3ObjectTask.CompleteMultipartUploadTask

Enclosing class:

S3ObjectTask

public static final class S3ObjectTask.CompleteMultipartUploadTask
extends S3ObjectTask

CompleteMultipartUploadTask.

Nested Class Summary

Nested classes/interfaces inherited from class alluxio.proxy.s3.S3ObjectTask

S3ObjectTask.CompleteMultipartUploadTask, S3ObjectTask.Factory

Nested classes/interfaces inherited from class alluxio.proxy.s3.S3BaseTask

S3BaseTask.OpTag, S3BaseTask.OpType

Field Summary

Fields inherited from class alluxio.proxy.s3.S3BaseTask

mHandler, mOPType

Constructor Summary

Constructors

Constructor and Description
CompleteMultipartUploadTask(S3Handler handler, S3BaseTask.OpType opType) Create a CompleteMultipartUploadTask.

Method Summary

Modifier and Type	Method and Description
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.
javax.ws.rs.core.Response	continueTask() Run core S3 API logic from different S3 task.
void	handleTaskAsync() Run S3 API logic in a customized async way, e.g.
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 alluxio.proxy.s3.S3ObjectTask

getObjectTaskResource

Methods inherited from class alluxio.proxy.s3.S3BaseTask

getOPType

Methods inherited from class java.lang.Object

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

Constructor Detail

CompleteMultipartUploadTask

public CompleteMultipartUploadTask(S3Handler handler,
                                   S3BaseTask.OpType opType)

Create a CompleteMultipartUploadTask.

Parameters:

handler -

opType -

Method Detail

handleTaskAsync

public void handleTaskAsync()

Description copied from class: S3BaseTask

Run S3 API logic in a customized async way, e.g. delegate the core API logic to another thread and do something while waiting.

Overrides:

handleTaskAsync in class S3BaseTask

continueTask

public javax.ws.rs.core.Response continueTask()

Description copied from class: S3BaseTask

Run core S3 API logic from different S3 task.

Overrides:

continueTask in class S3ObjectTask

Returns:

Response object containing common HTTP response properties

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