org.apache.flink.fs.s3.common.writer

Class S3Recoverable

java.lang.Object

org.apache.flink.fs.s3.common.writer.S3Recoverable

All Implemented Interfaces:

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

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

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

Method Summary

Modifier and Type	Method and Description
String	getObjectName()
long	incompleteObjectLength()
String	incompleteObjectName()
long	numBytesInParts()
List<com.amazonaws.services.s3.model.PartETag>	parts()
String	toString()
String	uploadId()

Methods inherited from class java.lang.Object

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

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()

toString

public String toString()

Overrides:

toString in class Object