org.kitesdk.morphline.hadoop.rcfile
Class SingleStreamFileSystem

java.lang.Object
  extended by org.apache.hadoop.conf.Configured
      extended by org.apache.hadoop.fs.FileSystem
          extended by 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


Copyright © 2013–2014. All rights reserved.