Uses of Class
org.apache.flink.fs.s3.common.writer.S3RecoverableWriter

Packages that use S3RecoverableWriter

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

Uses of S3RecoverableWriter in org.apache.flink.fs.s3.common.writer

Methods in org.apache.flink.fs.s3.common.writer that return S3RecoverableWriter

Modifier and Type	Method and Description
static S3RecoverableWriter	S3RecoverableWriter.writer(org.apache.hadoop.fs.FileSystem fs, org.apache.flink.util.function.FunctionWithException<File,RefCountedFile,IOException> tempFileCreator, S3AccessHelper s3AccessHelper, Executor uploadThreadPool, long userDefinedMinPartSize, int maxConcurrentUploadsPerStream)