org.apache.flink.fs.s3presto

Class S3PFileSystemFactory

java.lang.Object

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

org.apache.flink.fs.s3presto.S3FileSystemFactory

org.apache.flink.fs.s3presto.S3PFileSystemFactory

All Implemented Interfaces:

FileSystemFactory, Plugin

public class S3PFileSystemFactory
extends S3FileSystemFactory

Simple factory for the S3 file system, registered for the s3p:// scheme.

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
S3PFileSystemFactory()

Method Summary

Modifier and Type	Method and Description
String	getScheme() Gets the scheme of the file system created by this factory.

Methods inherited from class org.apache.flink.fs.s3presto.S3FileSystemFactory

createHadoopFileSystem, getInitURI, getS3AccessHelper

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

S3PFileSystemFactory

public S3PFileSystemFactory()

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 interface FileSystemFactory

Overrides:

getScheme in class S3FileSystemFactory