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

Class OSSRecoverable

java.lang.Object

org.apache.flink.fs.osshadoop.writer.OSSRecoverable

All Implemented Interfaces:

org.apache.flink.core.fs.RecoverableWriter.CommitRecoverable, org.apache.flink.core.fs.RecoverableWriter.ResumeRecoverable

public class OSSRecoverable
extends Object
implements org.apache.flink.core.fs.RecoverableWriter.ResumeRecoverable

Data object to recover an OSS MultiPartUpload for a recoverable output stream.

Constructor Summary

Constructors

Constructor	Description
OSSRecoverable(String uploadId, String objectName, List<com.aliyun.oss.model.PartETag> partETags, String lastPartObject, long numBytesInParts, long lastPartObjectLength)

Method Summary

Modifier and Type	Method	Description
String	getLastPartObject()
long	getLastPartObjectLength()
long	getNumBytesInParts()
String	getObjectName()
List<com.aliyun.oss.model.PartETag>	getPartETags()
String	getUploadId()

Methods inherited from class java.lang.Object

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

Constructor Detail

OSSRecoverable

public OSSRecoverable(String uploadId,
                      String objectName,
                      List<com.aliyun.oss.model.PartETag> partETags,
                      String lastPartObject,
                      long numBytesInParts,
                      long lastPartObjectLength)

Method Detail

getUploadId

public String getUploadId()

getObjectName

public String getObjectName()

getPartETags

public List<com.aliyun.oss.model.PartETag> getPartETags()

getLastPartObject

@Nullable
public String getLastPartObject()

getNumBytesInParts

public long getNumBytesInParts()

getLastPartObjectLength

public long getLastPartObjectLength()