public class S3FileSystemFactory extends AbstractS3FileSystemFactory
ACCESS_KEY, ENDPOINT, ENTROPY_INJECT_KEY_OPTION, ENTROPY_INJECT_LENGTH_OPTION, MAX_CONCURRENT_UPLOADS, PART_UPLOAD_MIN_SIZE, S5CMD_EXTRA_ARGS, S5CMD_PATH, SECRET_KEY
Constructor and Description |
---|
S3FileSystemFactory() |
Modifier and Type | Method and Description |
---|---|
protected FileSystem |
createFlinkFileSystem(org.apache.hadoop.fs.FileSystem fs,
FlinkS3FileSystem.S5CmdConfiguration s5CmdConfiguration,
String localTmpDirectory,
String entropyInjectionKey,
int numEntropyChars,
S3AccessHelper s3AccessHelper,
long s3minPartSize,
int maxConcurrentUploads) |
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
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
getClassLoader
public String getScheme()
FileSystemFactory
protected FileSystem createFlinkFileSystem(org.apache.hadoop.fs.FileSystem fs, @Nullable FlinkS3FileSystem.S5CmdConfiguration s5CmdConfiguration, String localTmpDirectory, String entropyInjectionKey, int numEntropyChars, S3AccessHelper s3AccessHelper, long s3minPartSize, int maxConcurrentUploads)
createFlinkFileSystem
in class AbstractS3FileSystemFactory
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.