Class 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 (a FileSystem).

    • Constructor Detail

      • HadoopFsFactory

        public HadoopFsFactory()
    • Method Detail

      • configure

        public void configure​(Configuration config)
        Description copied from interface: Plugin
        Optional method for plugins to pick up settings from the configuration.
        Specified by:
        configure in interface Plugin
        Parameters:
        config - The configuration to apply to the plugin.
      • 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.