public class S3FileSystemFactory extends AbstractS3FileSystemFactory
ENTROPY_INJECT_KEY_OPTION, ENTROPY_INJECT_LENGTH_OPTION, MAX_CONCURRENT_UPLOADS, PART_UPLOAD_MIN_SIZE
Constructor and Description |
---|
S3FileSystemFactory() |
Modifier and Type | Method and Description |
---|---|
protected org.apache.hadoop.fs.FileSystem |
createHadoopFileSystem() |
protected URI |
getInitURI(URI fsUri,
org.apache.hadoop.conf.Configuration hadoopConfig) |
protected S3AccessHelper |
getS3AccessHelper(org.apache.hadoop.fs.FileSystem fs) |
String |
getScheme()
Gets the scheme of the file system created by this factory.
|
configure, create, createFlinkFileSystem
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
getClassLoader
public String getScheme()
FileSystemFactory
protected org.apache.hadoop.fs.FileSystem createHadoopFileSystem()
createHadoopFileSystem
in class AbstractS3FileSystemFactory
protected URI getInitURI(URI fsUri, org.apache.hadoop.conf.Configuration hadoopConfig)
getInitURI
in class AbstractS3FileSystemFactory
@Nullable protected S3AccessHelper getS3AccessHelper(org.apache.hadoop.fs.FileSystem fs)
getS3AccessHelper
in class AbstractS3FileSystemFactory
Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.