Uses of Class
org.apache.flink.fs.osshadoop.OSSAccessor

Packages that use OSSAccessor

Package	Description
org.apache.flink.fs.osshadoop
org.apache.flink.fs.osshadoop.writer

Uses of OSSAccessor in org.apache.flink.fs.osshadoop

Constructors in org.apache.flink.fs.osshadoop with parameters of type OSSAccessor

Constructor and Description
FlinkOSSFileSystem(org.apache.hadoop.fs.FileSystem fileSystem, long ossUploadPartSize, int maxConcurrentUploadsPerStream, String localTmpDirectory, OSSAccessor ossAccessor)

Uses of OSSAccessor in org.apache.flink.fs.osshadoop.writer

Constructors in org.apache.flink.fs.osshadoop.writer with parameters of type OSSAccessor

Constructor and Description
OSSCommitter(OSSAccessor ossAccessor, String objectName, String uploadId, List<com.aliyun.oss.model.PartETag> partETags, long totalLength)
OSSRecoverableMultipartUpload(String objectName, Executor uploadThreadPool, OSSAccessor ossAccessor, Optional<File> incompletePart, String uploadId, List<com.aliyun.oss.model.PartETag> completeParts, long expectedSizeInBytes)
OSSRecoverableWriter(OSSAccessor ossAccessor, long ossUploadPartSize, int streamConcurrentUploads, Executor executor, FunctionWithException<File,RefCountedFileWithStream,IOException> cachedFileCreator)