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 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 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, org.apache.flink.util.function.FunctionWithException<File,org.apache.flink.core.fs.RefCountedFileWithStream,IOException> cachedFileCreator)
-