Package org.apache.flink.fs.osshadoop.writer

Class OSSRecoverableMultipartUpload

java.lang.Object

org.apache.flink.fs.osshadoop.writer.OSSRecoverableMultipartUpload

public class OSSRecoverableMultipartUpload
extends Object

Uploader for OSS multi part upload.

Constructor Summary

Constructors

Constructor	Description
OSSRecoverableMultipartUpload(String objectName, Executor uploadThreadPool, OSSAccessor ossAccessor, Optional<File> incompletePart, String uploadId, List<com.aliyun.oss.model.PartETag> completeParts, long expectedSizeInBytes)

Method Summary

Modifier and Type	Method	Description
OSSCommitter	getCommitter()
Optional<File>	getIncompletePart()
OSSRecoverable	getRecoverable(RefCountedFSOutputStream file)
void	uploadPart(RefCountedFSOutputStream file)

Methods inherited from class java.lang.Object

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

Constructor Detail

OSSRecoverableMultipartUpload

public OSSRecoverableMultipartUpload(String objectName,
                                     Executor uploadThreadPool,
                                     OSSAccessor ossAccessor,
                                     Optional<File> incompletePart,
                                     String uploadId,
                                     List<com.aliyun.oss.model.PartETag> completeParts,
                                     long expectedSizeInBytes)

Method Detail

getIncompletePart

public Optional<File> getIncompletePart()

uploadPart

public void uploadPart(RefCountedFSOutputStream file)
                throws IOException

Throws:

IOException

getRecoverable

public OSSRecoverable getRecoverable(RefCountedFSOutputStream file)
                              throws IOException

Throws:

IOException

getCommitter

public OSSCommitter getCommitter()
                          throws IOException

Throws:

IOException