public abstract class StreamedFileSystem extends FileSystem
FileSystem
implementations that manage remote resources.FileSystem.Statistics
FS_DEFAULT_NAME_KEY, LOG, 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 String |
getMD5SumFor(Configuration conf,
Path path) |
static String |
getMD5SumFor(Configuration conf,
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,
String md5Hex) |
static void |
setMD5SumFor(Configuration conf,
String path,
String md5Hex) |
void |
setWorkingDirectory(Path f) |
addFileSystemForTesting, append, append, checkPath, clearStatistics, close, closeAll, closeAllForUGI, completeLocalOutput, concat, copyFromLocalFile, copyFromLocalFile, copyFromLocalFile, copyFromLocalFile, copyToLocalFile, copyToLocalFile, create, create, create, create, create, create, create, create, create, create, createNewFile, createNonRecursive, createNonRecursive, deleteOnExit, exists, get, get, get, getAllStatistics, getBlockSize, getCacheSize, getCanonicalServiceName, getCanonicalUri, getContentSummary, getDefaultBlockSize, getDefaultBlockSize, getDefaultPort, getDefaultReplication, getDefaultReplication, getDefaultUri, getDelegationToken, getFileBlockLocations, getFileChecksum, getFileStatus, getHomeDirectory, getLength, getLocal, getName, getNamed, getReplication, getStatistics, getStatistics, getUri, getUsed, globStatus, globStatus, initialize, isDirectory, isFile, listStatus, listStatus, listStatus, makeQualified, mkdirs, mkdirs, moveFromLocalFile, moveFromLocalFile, moveToLocalFile, open, open, printStatistics, processDeleteOnExit, setDefaultUri, setDefaultUri, setOwner, setPermission, setReplication, setTimes, setVerifyChecksum, startLocalOutput
getConf, setConf
public StreamedFileSystem()
public FSDataOutputStream create(Path path, FsPermission permission, boolean overwrite, int bufferSize, short replication, long blockSize, Progressable progress) throws IOException
create
in class FileSystem
IOException
public boolean rename(Path path, Path path1) throws IOException
rename
in class FileSystem
IOException
@Deprecated public boolean delete(Path path) throws IOException
delete
in class FileSystem
IOException
public boolean delete(Path path, boolean b) throws IOException
delete
in class FileSystem
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 IOException
mkdirs
in class FileSystem
IOException
public FileStatus[] listStatus(Path path) throws IOException
listStatus
in class FileSystem
IOException
public FSDataOutputStream append(Path f, int bufferSize, Progressable progress) throws IOException
append
in class FileSystem
IOException
public static String getMD5SumFor(Configuration conf, Path path)
public static String getMD5SumFor(Configuration conf, String path)
public static void setMD5SumFor(Configuration conf, Path path, String md5Hex)
public static void setMD5SumFor(Configuration conf, String path, String md5Hex)
Copyright © 2007-2015 Concurrent, Inc. All Rights Reserved.