org.apache.flink.runtime.fs.maprfs

Class MapRFileSystem

java.lang.Object

org.apache.flink.core.fs.FileSystem

org.apache.flink.runtime.fs.hdfs.HadoopFileSystem

org.apache.flink.runtime.fs.maprfs.MapRFileSystem

public class MapRFileSystem
extends HadoopFileSystem

A MapR file system client for Flink.

Internally, this class wraps the FileSystem implementation of the MapR file system client.

Nested Class Summary

Nested classes/interfaces inherited from class org.apache.flink.core.fs.FileSystem

FileSystem.WriteMode

Constructor Summary

Constructors

Constructor and Description
MapRFileSystem(URI fsUri) Creates a MapRFileSystem for the given URI.

Method Summary

Modifier and Type	Method and Description
FileSystemKind	getKind() Gets a description of the characteristics of this file system.

Methods inherited from class org.apache.flink.runtime.fs.hdfs.HadoopFileSystem

create, create, delete, getDefaultBlockSize, getFileBlockLocations, getFileStatus, getHadoopFileSystem, getHomeDirectory, getUri, getWorkingDirectory, isDistributedFS, listStatus, mkdirs, open, open, rename

Methods inherited from class org.apache.flink.core.fs.FileSystem

create, exists, get, getDefaultFsUri, getLocalFileSystem, getUnguardedFileSystem, initialize, initOutPathDistFS, initOutPathLocalFS

Methods inherited from class java.lang.Object

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

Constructor Detail

MapRFileSystem

public MapRFileSystem(URI fsUri)
               throws IOException

Creates a MapRFileSystem for the given URI.

Parameters:

fsUri - The URI describing the file system

Throws:

IOException - Thrown if the file system could not be initialized.

Method Detail

getKind

public FileSystemKind getKind()

Description copied from class: FileSystem

Gets a description of the characteristics of this file system.

Overrides:

getKind in class HadoopFileSystem