org.apache.flink.fs.s3presto

Class S3FileSystemFactory

java.lang.Object

org.apache.flink.fs.s3.common.AbstractS3FileSystemFactory

org.apache.flink.fs.s3presto.S3FileSystemFactory

All Implemented Interfaces:

FileSystemFactory, Plugin

Direct Known Subclasses:

S3PFileSystemFactory

public class S3FileSystemFactory
extends AbstractS3FileSystemFactory

Simple factory for the S3 file system.

Field Summary

Fields inherited from class org.apache.flink.fs.s3.common.AbstractS3FileSystemFactory

ENTROPY_INJECT_KEY_OPTION, ENTROPY_INJECT_LENGTH_OPTION, MAX_CONCURRENT_UPLOADS, PART_UPLOAD_MIN_SIZE

Constructor Summary

Constructors

Constructor and Description
S3FileSystemFactory()

Method Summary

Modifier and Type	Method and Description
protected org.apache.hadoop.fs.FileSystem	createHadoopFileSystem()
protected URI	getInitURI(URI fsUri, Configuration hadoopConfig)
protected S3AccessHelper	getS3AccessHelper(org.apache.hadoop.fs.FileSystem fs)
String	getScheme() Gets the scheme of the file system created by this factory.

Methods inherited from class org.apache.flink.fs.s3.common.AbstractS3FileSystemFactory

configure, create

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

Constructor Detail

S3FileSystemFactory

public S3FileSystemFactory()

Method Detail

getScheme

public String getScheme()

Description copied from interface: FileSystemFactory

Gets the scheme of the file system created by this factory.

createHadoopFileSystem

protected org.apache.hadoop.fs.FileSystem createHadoopFileSystem()

Specified by:

createHadoopFileSystem in class AbstractS3FileSystemFactory

getInitURI

protected URI getInitURI(URI fsUri,
                         Configuration hadoopConfig)

Specified by:

getInitURI in class AbstractS3FileSystemFactory

getS3AccessHelper

@Nullable
protected S3AccessHelper getS3AccessHelper(org.apache.hadoop.fs.FileSystem fs)

Specified by:

getS3AccessHelper in class AbstractS3FileSystemFactory