Package org.apache.flink.runtime.fs.hdfs
Class HadoopFsFactory
- java.lang.Object
-
- org.apache.flink.runtime.fs.hdfs.HadoopFsFactory
-
- All Implemented Interfaces:
FileSystemFactory
,Plugin
public class HadoopFsFactory extends Object implements FileSystemFactory
A file system factory for Hadoop-based file systems.This factory calls Hadoop's mechanism to find a file system implementation for a given file system scheme (a
FileSystem
) and wraps it as a Flink file system (aFileSystem
).
-
-
Constructor Summary
Constructors Constructor Description HadoopFsFactory()
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description void
configure(Configuration config)
Optional method for plugins to pick up settings from the configuration.FileSystem
create(URI fsUri)
Creates a new file system for the given file system URI.String
getScheme()
Gets the scheme of the file system created by this factory.-
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
-
-
-
-
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 interfaceFileSystemFactory
-
configure
public void configure(Configuration config)
Description copied from interface:Plugin
Optional method for plugins to pick up settings from the configuration.
-
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 interfaceFileSystemFactory
- 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.
-
-