Class ThreadedS3Service

java.lang.Object
org.jets3t.service.multi.ThreadedStorageService
org.jets3t.service.multi.s3.ThreadedS3Service

public class ThreadedS3Service extends ThreadedStorageService
  • Constructor Details

  • Method Details

    • multipartStartUploads

      public boolean multipartStartUploads(String bucketName, List<StorageObject> objects)
      Starts multiple multipart uploads and sends MultipartStartsEvent 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 sends MultipartCompletesEvent 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 sends MultipartUploadsEvent 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.