alluxio.underfs

Interface MultipartUploader

public interface MultipartUploader

The multipart uploader interface to support multipart uploading. The interface is inspired by hadoop org.apache.hadoop.fs.impl.FileSystemMultipartUploader

Method Summary

Modifier and Type	Method and Description
void	abort() Aborts a multipart upload.
void	complete() Complete a multipart upload.
void	flush() Wait for the ongoing uploads to complete.
com.google.common.util.concurrent.ListenableFuture<Void>	putPart(ByteBuffer b, int partNumber) Put part as part of a multipart upload.
void	startUpload() Initialize a multipart upload.

Method Detail

startUpload

void startUpload()
          throws IOException

Initialize a multipart upload.

Throws:

IOException - IO failure

putPart

com.google.common.util.concurrent.ListenableFuture<Void> putPart(ByteBuffer b,
                                                                 int partNumber)
                                                          throws IOException

Put part as part of a multipart upload. It is possible to have parts uploaded in any order (or in parallel). stream after reading in the data.

Parameters:

b - the byte array to put. The byte buffer must have been flipped and be ready to read

partNumber - the part number of this file part

Returns:

a future of the async upload task

Throws:

IOException - IO failure

complete

void complete()
       throws IOException

Complete a multipart upload.

Throws:

IOException - IO failure

abort

void abort()
    throws IOException

Aborts a multipart upload.

Throws:

IOException - IO failure

flush

void flush()
    throws IOException

Wait for the ongoing uploads to complete.

Throws:

IOException - IO failure