public abstract class StreamedFileSystem extends FileSystem
FileSystem
implementations that manage remote resources.FileSystem.Statistics
DEFAULT_FS, FS_DEFAULT_NAME_KEY, LOG, SHUTDOWN_HOOK_PRIORITY, statistics
Constructor and Description |
---|
StreamedFileSystem() |
Modifier and Type | Method and Description |
---|---|
FSDataOutputStream |
append(Path f,
int bufferSize,
Progressable progress) |
FSDataOutputStream |
create(Path path,
FsPermission permission,
boolean overwrite,
int bufferSize,
short replication,
long blockSize,
Progressable progress) |
boolean |
delete(Path path)
Deprecated.
|
boolean |
delete(Path path,
boolean b) |
static java.lang.String |
getMD5SumFor(Configuration conf,
Path path) |
static java.lang.String |
getMD5SumFor(Configuration conf,
java.lang.String path) |
Path |
getWorkingDirectory() |
FileStatus[] |
listStatus(Path path) |
boolean |
mkdirs(Path path,
FsPermission fsPermission) |
boolean |
rename(Path path,
Path path1) |
static void |
setMD5SumFor(Configuration conf,
Path path,
java.lang.String md5Hex) |
static void |
setMD5SumFor(Configuration conf,
java.lang.String path,
java.lang.String md5Hex) |
void |
setWorkingDirectory(Path f) |
access, addDelegationTokens, append, append, areSymlinksEnabled, 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, createSnapshot, createSnapshot, createSymlink, deleteOnExit, deleteSnapshot, enableSymlinks, exists, fixRelativePart, get, get, get, getAclStatus, getAllStatistics, getBlockSize, getCanonicalServiceName, getCanonicalUri, getChildFileSystems, getContentSummary, getDefaultBlockSize, getDefaultBlockSize, getDefaultPort, getDefaultReplication, getDefaultReplication, getDefaultUri, getDelegationToken, getFileBlockLocations, getFileBlockLocations, getFileChecksum, getFileChecksum, getFileLinkStatus, getFileStatus, getFileSystemClass, getFSofPath, getHomeDirectory, getInitialWorkingDirectory, getLength, getLinkTarget, getLocal, getName, getNamed, getReplication, getScheme, getServerDefaults, getServerDefaults, getStatistics, getStatistics, getStatus, getStatus, getUri, getUsed, getXAttr, getXAttrs, getXAttrs, globStatus, globStatus, initialize, isDirectory, isFile, listCorruptFileBlocks, listFiles, listLocatedStatus, listLocatedStatus, listStatus, listStatus, listStatus, listStatusIterator, listXAttrs, makeQualified, mkdirs, mkdirs, modifyAclEntries, moveFromLocalFile, moveFromLocalFile, moveToLocalFile, newInstance, newInstance, newInstance, newInstanceLocal, open, open, primitiveCreate, primitiveMkdir, primitiveMkdir, printStatistics, processDeleteOnExit, removeAcl, removeAclEntries, removeDefaultAcl, removeXAttr, rename, renameSnapshot, resolveLink, resolvePath, setAcl, setDefaultUri, setDefaultUri, setOwner, setPermission, setReplication, setTimes, setVerifyChecksum, setWriteChecksum, setXAttr, setXAttr, startLocalOutput, supportsSymlinks, truncate
getConf, setConf
public StreamedFileSystem()
public FSDataOutputStream create(Path path, FsPermission permission, boolean overwrite, int bufferSize, short replication, long blockSize, Progressable progress) throws java.io.IOException
create
in class FileSystem
java.io.IOException
public boolean rename(Path path, Path path1) throws java.io.IOException
rename
in class FileSystem
java.io.IOException
@Deprecated public boolean delete(Path path) throws java.io.IOException
delete
in class FileSystem
java.io.IOException
public boolean delete(Path path, boolean b) throws java.io.IOException
delete
in class FileSystem
java.io.IOException
public Path getWorkingDirectory()
getWorkingDirectory
in class FileSystem
public void setWorkingDirectory(Path f)
setWorkingDirectory
in class FileSystem
public boolean mkdirs(Path path, FsPermission fsPermission) throws java.io.IOException
mkdirs
in class FileSystem
java.io.IOException
public FileStatus[] listStatus(Path path) throws java.io.IOException
listStatus
in class FileSystem
java.io.IOException
public FSDataOutputStream append(Path f, int bufferSize, Progressable progress) throws java.io.IOException
append
in class FileSystem
java.io.IOException
public static java.lang.String getMD5SumFor(Configuration conf, Path path)
public static java.lang.String getMD5SumFor(Configuration conf, java.lang.String path)
public static void setMD5SumFor(Configuration conf, Path path, java.lang.String md5Hex)
public static void setMD5SumFor(Configuration conf, java.lang.String path, java.lang.String md5Hex)
Copyright © 2007-2015 Xplenty, Inc. All Rights Reserved.