Package org.apache.flink.fs.s3hadoop
Class S3AFileSystemFactory
- java.lang.Object
-
- org.apache.flink.fs.s3.common.AbstractS3FileSystemFactory
-
- org.apache.flink.fs.s3hadoop.S3FileSystemFactory
-
- org.apache.flink.fs.s3hadoop.S3AFileSystemFactory
-
- All Implemented Interfaces:
FileSystemFactory
,Plugin
public class S3AFileSystemFactory extends S3FileSystemFactory
Simple factory for the S3 file system, registered for the s3a:// scheme.
-
-
Field Summary
-
Fields inherited from class org.apache.flink.fs.s3.common.AbstractS3FileSystemFactory
ACCESS_KEY, ENDPOINT, ENTROPY_INJECT_KEY_OPTION, ENTROPY_INJECT_LENGTH_OPTION, MAX_CONCURRENT_UPLOADS, PART_UPLOAD_MIN_SIZE, S5CMD_BATCH_MAX_FILES, S5CMD_BATCH_MAX_SIZE, S5CMD_EXTRA_ARGS, S5CMD_PATH, SECRET_KEY
-
-
Constructor Summary
Constructors Constructor Description S3AFileSystemFactory()
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description String
getScheme()
Gets the scheme of the file system created by this factory.-
Methods inherited from class org.apache.flink.fs.s3hadoop.S3FileSystemFactory
createHadoopFileSystem, getInitURI, getS3AccessHelper
-
Methods inherited from class org.apache.flink.fs.s3.common.AbstractS3FileSystemFactory
configure, create, createFlinkFileSystem
-
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
-
Methods inherited from interface org.apache.flink.core.plugin.Plugin
getClassLoader
-
-
-
-
Method Detail
-
getScheme
public String getScheme()
Description copied from interface:FileSystemFactory
Gets the scheme of the file system created by this factory.- Specified by:
getScheme
in interfaceFileSystemFactory
- Overrides:
getScheme
in classS3FileSystemFactory
-
-