Class S3Recoverable
- java.lang.Object
-
- org.apache.flink.fs.s3.common.writer.S3Recoverable
-
- All Implemented Interfaces:
RecoverableWriter.CommitRecoverable
,RecoverableWriter.ResumeRecoverable
public final class S3Recoverable extends Object implements RecoverableWriter.ResumeRecoverable
Data object to recover an S3 MultiPartUpload for a recoverable output stream.
-
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description String
getObjectName()
long
incompleteObjectLength()
String
incompleteObjectName()
long
numBytesInParts()
List<com.amazonaws.services.s3.model.PartETag>
parts()
String
toString()
String
uploadId()
-
-
-
Method Detail
-
uploadId
public String uploadId()
-
getObjectName
public String getObjectName()
-
parts
public List<com.amazonaws.services.s3.model.PartETag> parts()
-
numBytesInParts
public long numBytesInParts()
-
incompleteObjectName
@Nullable public String incompleteObjectName()
-
incompleteObjectLength
public long incompleteObjectLength()
-
-