Package org.jets3t.service.multi.s3
Class ThreadedS3Service
- java.lang.Object
-
- org.jets3t.service.multi.ThreadedStorageService
-
- org.jets3t.service.multi.s3.ThreadedS3Service
-
public class ThreadedS3Service extends ThreadedStorageService
-
-
Constructor Summary
Constructors Constructor Description ThreadedS3Service(S3Service service, StorageServiceEventListener listener)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description boolean
multipartCompleteUploads(List<MultipartUpload> multipartUploads)
Completes multiple multipart uploads and sendsMultipartCompletesEvent
notification events.boolean
multipartStartUploads(String bucketName, List<StorageObject> objects)
Starts multiple multipart uploads and sendsMultipartStartsEvent
notification events.boolean
multipartUploadParts(List<MultipartUploadAndParts> uploadAndPartsList)
Uploads multiple objects that will constitute a single final object, and sendsMultipartUploadsEvent
notification events.-
Methods inherited from class org.jets3t.service.multi.ThreadedStorageService
addServiceEventListener, copyObjects, createBuckets, deleteObjects, deleteObjects, downloadObjects, getObjectACLs, getObjects, getObjects, getObjectsHeads, getObjectsHeads, getProviderCredentials, getStorageService, isAuthenticatedConnection, isShutdown, listObjects, putACLs, putObjects, removeServiceEventListener, shutdown
-
-
-
-
Constructor Detail
-
ThreadedS3Service
public ThreadedS3Service(S3Service service, StorageServiceEventListener listener) throws ServiceException
- Throws:
ServiceException
-
-
Method Detail
-
multipartStartUploads
public boolean multipartStartUploads(String bucketName, List<StorageObject> objects)
Starts multiple multipart uploads and sendsMultipartStartsEvent
notification events.The maximum number of threads is controlled by the JetS3t configuration property threaded-service.max-admin-thread-count.
- Parameters:
bucketName
- the target bucket.objects
- a list of objects representing the overall multipart object.- Returns:
- true if all the threaded tasks completed successfully, false otherwise.
-
multipartCompleteUploads
public boolean multipartCompleteUploads(List<MultipartUpload> multipartUploads)
Completes multiple multipart uploads and sendsMultipartCompletesEvent
notification events.The maximum number of threads is controlled by the JetS3t configuration property threaded-service.max-admin-thread-count.
- Parameters:
multipartUploads
- a list of objects representing the multipart-uploads that will be completed.- Returns:
- true if all the threaded tasks completed successfully, false otherwise.
-
multipartUploadParts
public boolean multipartUploadParts(List<MultipartUploadAndParts> uploadAndPartsList)
Uploads multiple objects that will constitute a single final object, and sendsMultipartUploadsEvent
notification events.The maximum number of threads is controlled by the JetS3t configuration property threaded-service.max-admin-thread-count.
- Parameters:
uploadAndPartsList
- list of wrapper objects containing a previously-started MultipartUpload and a list of objects representing the parts that will make up the final object.- Returns:
- true if all the threaded tasks completed successfully, false otherwise.
-
-