org.kitesdk.morphline.hadoop.rcfile
Class SingleStreamFileSystem

java.lang.Object
  org.apache.hadoop.conf.Configured
      org.apache.hadoop.fs.FileSystem
          org.kitesdk.morphline.hadoop.rcfile.SingleStreamFileSystem

All Implemented Interfaces:

Closeable, Configurable

public final class SingleStreamFileSystem
extends FileSystem

Very simple Filesystem Implementation which serves an InputStream for a given path. This is used to serve the underlying input stream from a FileSystem Interface. Only open() and getFileStatus() is implemented.

Nested Class Summary

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

FileSystem.Statistics

Field Summary

Fields inherited from class org.apache.hadoop.fs.FileSystem

DEFAULT_FS, FS_DEFAULT_NAME_KEY, LOG, SHUTDOWN_HOOK_PRIORITY, statistics

Constructor Summary

SingleStreamFileSystem(InputStream inputStream, Path path)

Method Summary

FSDataOutputStream	append(Path f, int bufferSize, Progressable progress)
FSDataOutputStream	create(Path f, FsPermission permission, boolean overwrite, int bufferSize, short replication, long blockSize, Progressable progress)
boolean	delete(Path f, boolean recursive)
FileStatus	getFileStatus(Path f)
URI	getUri()
Path	getWorkingDirectory()
FileStatus[]	listStatus(Path f)
boolean	mkdirs(Path f, FsPermission permission)
FSDataInputStream	open(Path f, int bufferSize)
boolean	rename(Path src, Path dst)
void	setWorkingDirectory(Path new_dir)

Methods inherited from class org.apache.hadoop.fs.FileSystem

addDelegationTokens, append, append, cancelDeleteOnExit, canonicalizeUri, checkPath, clearStatistics, close, closeAll, closeAllForUGI, completeLocalOutput, concat, copyFromLocalFile, copyFromLocalFile, copyFromLocalFile, copyFromLocalFile, copyToLocalFile, copyToLocalFile, copyToLocalFile, create, create, create, create, create, create, create, create, create, create, create, create, createNewFile, createNonRecursive, createNonRecursive, createNonRecursive, delete, deleteOnExit, exists, get, get, get, getAllStatistics, getBlockSize, getCanonicalServiceName, getCanonicalUri, getChildFileSystems, getContentSummary, getDefaultBlockSize, getDefaultBlockSize, getDefaultPort, getDefaultReplication, getDefaultReplication, getDefaultUri, getDelegationToken, getFileBlockLocations, getFileBlockLocations, getFileChecksum, getFileSystemClass, getHomeDirectory, getInitialWorkingDirectory, getLength, getLocal, getName, getNamed, getReplication, getScheme, getServerDefaults, getServerDefaults, getStatistics, getStatistics, getStatus, getStatus, getUsed, globStatus, globStatus, initialize, isDirectory, isFile, listCorruptFileBlocks, listFiles, listLocatedStatus, listLocatedStatus, listStatus, listStatus, listStatus, makeQualified, mkdirs, mkdirs, moveFromLocalFile, moveFromLocalFile, moveToLocalFile, newInstance, newInstance, newInstance, newInstanceLocal, open, primitiveCreate, primitiveMkdir, primitiveMkdir, printStatistics, processDeleteOnExit, rename, resolvePath, setDefaultUri, setDefaultUri, setOwner, setPermission, setReplication, setTimes, setVerifyChecksum, setWriteChecksum, startLocalOutput

Methods inherited from class org.apache.hadoop.conf.Configured

getConf, setConf

Methods inherited from class java.lang.Object

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

Constructor Detail

SingleStreamFileSystem

public SingleStreamFileSystem(InputStream inputStream,
                              Path path)
                       throws IOException

Throws:

IOException

Method Detail

getUri

public URI getUri()

Specified by:

getUri in class FileSystem

open

public FSDataInputStream open(Path f,
                              int bufferSize)
                       throws IOException

Specified by:

open in class FileSystem

Throws:

IOException

create

public FSDataOutputStream create(Path f,
                                 FsPermission permission,
                                 boolean overwrite,
                                 int bufferSize,
                                 short replication,
                                 long blockSize,
                                 Progressable progress)
                          throws IOException

Specified by:

create in class FileSystem

Throws:

IOException

append

public FSDataOutputStream append(Path f,
                                 int bufferSize,
                                 Progressable progress)
                          throws IOException

Specified by:

append in class FileSystem

Throws:

IOException

rename

public boolean rename(Path src,
                      Path dst)
               throws IOException

Specified by:

rename in class FileSystem

Throws:

IOException

delete

public boolean delete(Path f,
                      boolean recursive)
               throws IOException

Specified by:

delete in class FileSystem

Throws:

IOException

listStatus

public FileStatus[] listStatus(Path f)
                        throws FileNotFoundException,
                               IOException

Specified by:

listStatus in class FileSystem

Throws:

FileNotFoundException

IOException

setWorkingDirectory

public void setWorkingDirectory(Path new_dir)

Specified by:

setWorkingDirectory in class FileSystem

getWorkingDirectory

public Path getWorkingDirectory()

Specified by:

getWorkingDirectory in class FileSystem

mkdirs

public boolean mkdirs(Path f,
                      FsPermission permission)
               throws IOException

Specified by:

mkdirs in class FileSystem

Throws:

IOException

getFileStatus

public FileStatus getFileStatus(Path f)
                         throws IOException

Specified by:

getFileStatus in class FileSystem

Throws:

IOException