org.apache.flink.connectors.hive

Class HadoopFileSystemFactory

java.lang.Object

org.apache.flink.connectors.hive.HadoopFileSystemFactory

All Implemented Interfaces:

Serializable, FileSystemFactory

public class HadoopFileSystemFactory
extends Object
implements FileSystemFactory

Hive FileSystemFactory, hive need use job conf to create file system.

See Also:

Serialized Form

Method Summary

Modifier and Type	Method and Description
FileSystem	create(URI uri) Creates a new file system for the given file system URI.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Method Detail

create

public FileSystem create(URI uri)
                  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:

uri - 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.