org.apache.flink.runtime.fs.hdfs

Class AbstractFileSystemFactory

java.lang.Object

org.apache.flink.runtime.fs.hdfs.AbstractFileSystemFactory

All Implemented Interfaces:

FileSystemFactory

Direct Known Subclasses:

S3FileSystemFactory

public abstract class AbstractFileSystemFactory
extends Object
implements FileSystemFactory

Base class for Hadoop file system factories.

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	AbstractFileSystemFactory(String name, HadoopConfigLoader hadoopConfigLoader)

Method Summary

Modifier and Type	Method and Description
void	configure(Configuration config) Applies the given configuration to this factory.
FileSystem	create(URI fsUri) Creates a new file system for the given file system URI.
protected abstract org.apache.hadoop.fs.FileSystem	createHadoopFileSystem()
protected abstract URI	getInitURI(URI fsUri, Configuration hadoopConfig)

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.fs.FileSystemFactory

getScheme

Constructor Detail

AbstractFileSystemFactory

protected AbstractFileSystemFactory(String name,
                                    HadoopConfigLoader hadoopConfigLoader)

Method Detail

configure

public void configure(Configuration config)

Description copied from interface: FileSystemFactory

Applies the given configuration to this factory. All future file system instantiations via FileSystemFactory.create(URI) should take the configuration into account.

Specified by:

configure in interface FileSystemFactory

Parameters:

config - The configuration to apply.

create

public FileSystem create(URI fsUri)
                  throws IOException

Description copied from interface: FileSystemFactory

Creates a new file system for the given file system URI. The URI describes the type of file system (via its scheme) and optionally the authority (for example the host) of the file system.

Specified by:

create in interface FileSystemFactory

Parameters:

fsUri - The URI that describes the file system.

Returns:

A new instance of the specified file system.

Throws:

IOException - Thrown if the file system could not be instantiated.

createHadoopFileSystem

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

getInitURI

protected abstract URI getInitURI(URI fsUri,
                                  Configuration hadoopConfig)