HadoopFsFactory (Flink : FileSystems : Hadoop FS 2.2.0 API)

java.lang.Object
- org.apache.flink.runtime.fs.hdfs.HadoopFsFactory

All Implemented Interfaces:

org.apache.flink.core.fs.FileSystemFactory, org.apache.flink.core.plugin.Plugin
```
public class HadoopFsFactory
extends Object
implements org.apache.flink.core.fs.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 (a FileSystem).

Constructor Summary

Constructors
Constructor Description

HadoopFsFactory()

Method Summary

All Methods Instance Methods Concrete Methods
Modifier and Type	Method	Description
`void`	`configure(org.apache.flink.configuration.Configuration config)`
`org.apache.flink.core.fs.FileSystem`	`create(URI fsUri)`
`String`	`getScheme()`

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
  - HadoopFsFactory
```
public HadoopFsFactory()
```
- Method Detail
  - getScheme
```
public String getScheme()
```
    Specified by:
    
    getScheme in interface org.apache.flink.core.fs.FileSystemFactory
  - configure
```
public void configure(org.apache.flink.configuration.Configuration config)
```
    Specified by:
    
    configure in interface org.apache.flink.core.plugin.Plugin
  - create
```
public org.apache.flink.core.fs.FileSystem create(URI fsUri)
                                           throws IOException
```
    Specified by:
    
    create in interface org.apache.flink.core.fs.FileSystemFactory
    
    Throws:
    
    IOException