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.
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 java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
SingleStreamFileSystem
public SingleStreamFileSystem(InputStream inputStream,
Path path)
throws IOException
- Throws:
IOException
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.