static S3RecoverableFsDataOutputStream |
S3RecoverableFsDataOutputStream.newStream(org.apache.flink.fs.s3.common.writer.RecoverableMultiPartUpload upload,
FunctionWithException<File,RefCountedFile,IOException> tmpFileCreator,
long userDefinedMinPartSize) |
S3RecoverableFsDataOutputStream |
S3RecoverableWriter.recover(RecoverableWriter.ResumeRecoverable recoverable) |
static S3RecoverableFsDataOutputStream |
S3RecoverableFsDataOutputStream.recoverStream(org.apache.flink.fs.s3.common.writer.RecoverableMultiPartUpload upload,
FunctionWithException<File,RefCountedFile,IOException> tmpFileCreator,
long userDefinedMinPartSize,
long bytesBeforeCurrentPart) |