public class CompleteMultipartUpload extends java.lang.Object implements java.util.concurrent.Callable<UploadResult>
Modifier and Type | Field and Description |
---|---|
private java.util.List<PartETag> |
eTagsBeforeResume
The eTags of the parts that had been successfully uploaded before
resuming a paused upload.
|
private java.util.List<java.util.concurrent.Future<PartETag>> |
futures
The futures of threads that upload individual parts.
|
private ProgressListenerChain |
listener
The listener where progress of the upload needs to be published.
|
private UploadMonitor |
monitor
The monitor to which the upload progress has to be communicated.
|
private PutObjectRequest |
origReq
The reference to the request initiated by the user.
|
private AmazonS3 |
s3
The reference to underlying Amazon S3 client to be used for initiating
requests to Amazon S3.
|
private java.lang.String |
uploadId
The upload id associated with the multi-part upload.
|
Constructor and Description |
---|
CompleteMultipartUpload(java.lang.String uploadId,
AmazonS3 s3,
PutObjectRequest putObjectRequest,
java.util.List<java.util.concurrent.Future<PartETag>> futures,
java.util.List<PartETag> eTagsBeforeResume,
ProgressListenerChain progressListenerChain,
UploadMonitor monitor) |
Modifier and Type | Method and Description |
---|---|
UploadResult |
call() |
private java.util.List<PartETag> |
collectPartETags()
Collects the Part ETags for initiating the complete multi-part upload
request.
|
private final java.lang.String uploadId
private final AmazonS3 s3
private final PutObjectRequest origReq
private final java.util.List<java.util.concurrent.Future<PartETag>> futures
private final java.util.List<PartETag> eTagsBeforeResume
private final UploadMonitor monitor
private final ProgressListenerChain listener
public CompleteMultipartUpload(java.lang.String uploadId, AmazonS3 s3, PutObjectRequest putObjectRequest, java.util.List<java.util.concurrent.Future<PartETag>> futures, java.util.List<PartETag> eTagsBeforeResume, ProgressListenerChain progressListenerChain, UploadMonitor monitor)
public UploadResult call() throws java.lang.Exception
call
in interface java.util.concurrent.Callable<UploadResult>
java.lang.Exception
private java.util.List<PartETag> collectPartETags()