Uses of Class
org.apache.flink.fs.s3.common.utils.RefCountedFile

Packages that use RefCountedFile

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

Uses of RefCountedFile in org.apache.flink.fs.s3.common.utils

Methods in org.apache.flink.fs.s3.common.utils that return RefCountedFile

Modifier and Type	Method and Description
RefCountedFile	RefCountedTmpFileCreator.apply(File file) Gets the next temp file and stream to temp file.
static RefCountedFile	RefCountedFile.newFile(File file, OutputStream currentOut)
static RefCountedFile	RefCountedFile.restoredFile(File file, OutputStream currentOut, long bytesInCurrentPart)

Method parameters in org.apache.flink.fs.s3.common.utils with type arguments of type RefCountedFile

Modifier and Type	Method and Description
static RefCountedBufferingFileStream	RefCountedBufferingFileStream.openNew(org.apache.flink.util.function.FunctionWithException<File,RefCountedFile,IOException> tmpFileProvider)
static RefCountedBufferingFileStream	RefCountedBufferingFileStream.restore(org.apache.flink.util.function.FunctionWithException<File,RefCountedFile,IOException> tmpFileProvider, File initialTmpFile)

Constructors in org.apache.flink.fs.s3.common.utils with parameters of type RefCountedFile

Constructor and Description
RefCountedBufferingFileStream(RefCountedFile file, int bufferSize)

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

Method parameters in org.apache.flink.fs.s3.common.writer with type arguments of type RefCountedFile

Modifier and Type	Method and Description
static S3RecoverableFsDataOutputStream	S3RecoverableFsDataOutputStream.newStream(org.apache.flink.fs.s3.common.writer.RecoverableMultiPartUpload upload, org.apache.flink.util.function.FunctionWithException<File,RefCountedFile,IOException> tmpFileCreator, long userDefinedMinPartSize)
static S3RecoverableFsDataOutputStream	S3RecoverableFsDataOutputStream.recoverStream(org.apache.flink.fs.s3.common.writer.RecoverableMultiPartUpload upload, org.apache.flink.util.function.FunctionWithException<File,RefCountedFile,IOException> tmpFileCreator, long userDefinedMinPartSize, long bytesBeforeCurrentPart)
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)