|
|||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Object org.apache.hadoop.conf.Configured org.apache.hadoop.fs.FileSystem cascading.tap.hadoop.io.StreamedFileSystem
public abstract class StreamedFileSystem
Class StreamedFileSystem is a base class for FileSystem
implementations that manage remote resources.
Nested Class Summary |
---|
Nested classes/interfaces inherited from class org.apache.hadoop.fs.FileSystem |
---|
org.apache.hadoop.fs.FileSystem.Statistics |
Field Summary |
---|
Fields inherited from class org.apache.hadoop.fs.FileSystem |
---|
FS_DEFAULT_NAME_KEY, LOG, statistics |
Constructor Summary | |
---|---|
StreamedFileSystem()
|
Method Summary | |
---|---|
org.apache.hadoop.fs.FSDataOutputStream |
append(org.apache.hadoop.fs.Path f,
int bufferSize,
org.apache.hadoop.util.Progressable progress)
|
org.apache.hadoop.fs.FSDataOutputStream |
create(org.apache.hadoop.fs.Path path,
org.apache.hadoop.fs.permission.FsPermission permission,
boolean overwrite,
int bufferSize,
short replication,
long blockSize,
org.apache.hadoop.util.Progressable progress)
|
boolean |
delete(org.apache.hadoop.fs.Path path)
Deprecated. |
boolean |
delete(org.apache.hadoop.fs.Path path,
boolean b)
|
static String |
getMD5SumFor(org.apache.hadoop.conf.Configuration conf,
org.apache.hadoop.fs.Path path)
|
static String |
getMD5SumFor(org.apache.hadoop.conf.Configuration conf,
String path)
|
org.apache.hadoop.fs.Path |
getWorkingDirectory()
|
org.apache.hadoop.fs.FileStatus[] |
listStatus(org.apache.hadoop.fs.Path path)
|
boolean |
mkdirs(org.apache.hadoop.fs.Path path,
org.apache.hadoop.fs.permission.FsPermission fsPermission)
|
boolean |
rename(org.apache.hadoop.fs.Path path,
org.apache.hadoop.fs.Path path1)
|
static void |
setMD5SumFor(org.apache.hadoop.conf.Configuration conf,
org.apache.hadoop.fs.Path path,
String md5Hex)
|
static void |
setMD5SumFor(org.apache.hadoop.conf.Configuration conf,
String path,
String md5Hex)
|
void |
setWorkingDirectory(org.apache.hadoop.fs.Path f)
|
Methods inherited from class org.apache.hadoop.fs.FileSystem |
---|
addFileSystemForTesting, append, append, checkPath, clearStatistics, close, closeAll, closeAllForUGI, completeLocalOutput, 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, 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 |
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 |
---|
public StreamedFileSystem()
Method Detail |
---|
public org.apache.hadoop.fs.FSDataOutputStream create(org.apache.hadoop.fs.Path path, org.apache.hadoop.fs.permission.FsPermission permission, boolean overwrite, int bufferSize, short replication, long blockSize, org.apache.hadoop.util.Progressable progress) throws IOException
create
in class org.apache.hadoop.fs.FileSystem
IOException
public boolean rename(org.apache.hadoop.fs.Path path, org.apache.hadoop.fs.Path path1) throws IOException
rename
in class org.apache.hadoop.fs.FileSystem
IOException
@Deprecated public boolean delete(org.apache.hadoop.fs.Path path) throws IOException
delete
in class org.apache.hadoop.fs.FileSystem
IOException
public boolean delete(org.apache.hadoop.fs.Path path, boolean b) throws IOException
delete
in class org.apache.hadoop.fs.FileSystem
IOException
public org.apache.hadoop.fs.Path getWorkingDirectory()
getWorkingDirectory
in class org.apache.hadoop.fs.FileSystem
public void setWorkingDirectory(org.apache.hadoop.fs.Path f)
setWorkingDirectory
in class org.apache.hadoop.fs.FileSystem
public boolean mkdirs(org.apache.hadoop.fs.Path path, org.apache.hadoop.fs.permission.FsPermission fsPermission) throws IOException
mkdirs
in class org.apache.hadoop.fs.FileSystem
IOException
public org.apache.hadoop.fs.FileStatus[] listStatus(org.apache.hadoop.fs.Path path) throws IOException
listStatus
in class org.apache.hadoop.fs.FileSystem
IOException
public org.apache.hadoop.fs.FSDataOutputStream append(org.apache.hadoop.fs.Path f, int bufferSize, org.apache.hadoop.util.Progressable progress) throws IOException
append
in class org.apache.hadoop.fs.FileSystem
IOException
public static String getMD5SumFor(org.apache.hadoop.conf.Configuration conf, org.apache.hadoop.fs.Path path)
public static String getMD5SumFor(org.apache.hadoop.conf.Configuration conf, String path)
public static void setMD5SumFor(org.apache.hadoop.conf.Configuration conf, org.apache.hadoop.fs.Path path, String md5Hex)
public static void setMD5SumFor(org.apache.hadoop.conf.Configuration conf, String path, String md5Hex)
|
|||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |