org.apache.flink.connectors.hive

Class HadoopFileSystemFactory

java.lang.Object

org.apache.flink.connectors.hive.HadoopFileSystemFactory

All Implemented Interfaces:

Serializable, org.apache.flink.table.filesystem.FileSystemFactory

public class HadoopFileSystemFactory
extends Object
implements org.apache.flink.table.filesystem.FileSystemFactory

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

See Also:

Serialized Form

Method Summary

Modifier and Type	Method and Description
org.apache.flink.core.fs.FileSystem	create(URI uri)

Methods inherited from class java.lang.Object

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

Method Detail

create

public org.apache.flink.core.fs.FileSystem create(URI uri)
                                           throws IOException

Specified by:

create in interface org.apache.flink.table.filesystem.FileSystemFactory

Throws:

IOException