Class GenericMultipartHelper<RequestT extends S3Request,ResponseT extends S3Response>

java.lang.Object

software.amazon.awssdk.services.s3.internal.multipart.GenericMultipartHelper<RequestT,ResponseT>

public final class GenericMultipartHelper<RequestT extends S3Request,ResponseT extends S3Response>
extends Object

Constructor Summary

Constructors

Constructor	Description
GenericMultipartHelper(S3AsyncClient s3AsyncClient, Function<RequestT,AbortMultipartUploadRequest.Builder> abortMultipartUploadRequestConverter, Function<CompleteMultipartUploadResponse,ResponseT> responseConverter)

Method Summary

Modifier and Type	Method	Description
long	calculateOptimalPartSizeFor(long contentLengthOfSource, long partSizeInBytes)
void	cleanUpParts(String uploadId, AbortMultipartUploadRequest.Builder abortMultipartUploadRequest)
CompletableFuture<CompleteMultipartUploadResponse>	completeMultipartUpload(PutObjectRequest request, String uploadId, CompletedPart[] parts, long contentLength)
int	determinePartCount(long contentLength, long partSize)
void	handleException(CompletableFuture<ResponseT> returnFuture, Supplier<String> message, Throwable throwable)
BiFunction<CompleteMultipartUploadResponse,Throwable,Void>	handleExceptionOrResponse(RequestT request, CompletableFuture<ResponseT> returnFuture, String uploadId)

Methods inherited from class java.lang.Object

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

Constructor Details

GenericMultipartHelper

public GenericMultipartHelper(S3AsyncClient s3AsyncClient,
 Function<RequestT,AbortMultipartUploadRequest.Builder> abortMultipartUploadRequestConverter,
 Function<CompleteMultipartUploadResponse,ResponseT> responseConverter)

Method Details

handleException

public void handleException(CompletableFuture<ResponseT> returnFuture,
 Supplier<String> message,
 Throwable throwable)

calculateOptimalPartSizeFor

public long calculateOptimalPartSizeFor(long contentLengthOfSource,
 long partSizeInBytes)

determinePartCount

public int determinePartCount(long contentLength,
 long partSize)

completeMultipartUpload

public CompletableFuture<CompleteMultipartUploadResponse> completeMultipartUpload(PutObjectRequest request,
 String uploadId,
 CompletedPart[] parts,
 long contentLength)

handleExceptionOrResponse

public BiFunction<CompleteMultipartUploadResponse,Throwable,Void> handleExceptionOrResponse(RequestT request,
 CompletableFuture<ResponseT> returnFuture,
 String uploadId)

cleanUpParts

public void cleanUpParts(String uploadId,
 AbortMultipartUploadRequest.Builder abortMultipartUploadRequest)