public class KosmosFileSystem extends FileSystem
FileSystem.Statistics
FS_DEFAULT_NAME_KEY, LOG, statistics
构造器和说明 |
---|
KosmosFileSystem() |
限定符和类型 | 方法和说明 |
---|---|
FSDataOutputStream |
append(Path f,
int bufferSize,
Progressable progress)
This optional operation is not yet supported.
|
void |
completeLocalOutput(Path fsOutputFile,
Path tmpLocalFile)
Called when we're all done writing to the target.
|
void |
copyFromLocalFile(boolean delSrc,
Path src,
Path dst)
The src file is on the local disk.
|
void |
copyToLocalFile(boolean delSrc,
Path src,
Path dst)
The src file is under FS, and the dst is on the local disk.
|
FSDataOutputStream |
create(Path file,
FsPermission permission,
boolean overwrite,
int bufferSize,
short replication,
long blockSize,
Progressable progress)
Opens an FSDataOutputStream at the indicated Path with write-progress
reporting.
|
boolean |
delete(Path path)
已过时。
|
boolean |
delete(Path path,
boolean recursive)
Delete a file.
|
long |
getDefaultBlockSize()
Return the number of bytes that large input files should be optimally
be split into to minimize i/o time.
|
short |
getDefaultReplication()
Get the default replication.
|
BlockLocation[] |
getFileBlockLocations(FileStatus file,
long start,
long len)
Return null if the file doesn't exist; otherwise, get the
locations of the various chunks of the file file from KFS.
|
FileStatus |
getFileStatus(Path path)
Return a file status object that represents the path.
|
long |
getLength(Path path)
已过时。
|
String |
getName()
已过时。
|
short |
getReplication(Path path)
已过时。
|
URI |
getUri()
Returns a URI whose scheme and authority identify this FileSystem.
|
Path |
getWorkingDirectory()
Get the current working directory for the given file system
|
void |
initialize(URI uri,
Configuration conf)
Called after a new FileSystem instance is constructed.
|
boolean |
isDirectory(Path path)
已过时。
|
boolean |
isFile(Path path)
已过时。
|
FileStatus[] |
listStatus(Path path)
List the statuses of the files/directories in the given path if the path is
a directory.
|
void |
lock(Path path,
boolean shared)
已过时。
|
boolean |
mkdirs(Path path,
FsPermission permission)
Make the given file and all non-existent parents into
directories.
|
FSDataInputStream |
open(Path path,
int bufferSize)
Opens an FSDataInputStream at the indicated Path.
|
void |
release(Path path)
已过时。
|
boolean |
rename(Path src,
Path dst)
Renames Path src to Path dst.
|
boolean |
setReplication(Path path,
short replication)
Set replication for an existing file.
|
void |
setWorkingDirectory(Path dir)
Set the current working directory for the given file system.
|
Path |
startLocalOutput(Path fsOutputFile,
Path tmpLocalFile)
Returns a local File that the user can write output to.
|
addFileSystemForTesting, append, append, checkPath, clearStatistics, close, closeAll, closeAllForUGI, concat, copyFromLocalFile, copyFromLocalFile, copyFromLocalFile, 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, getDefaultPort, getDefaultReplication, getDefaultUri, getDelegationToken, getFileChecksum, getHomeDirectory, getLocal, getNamed, getStatistics, getStatistics, getUsed, globStatus, globStatus, listStatus, listStatus, listStatus, makeQualified, mkdirs, mkdirs, moveFromLocalFile, moveFromLocalFile, moveToLocalFile, open, printStatistics, processDeleteOnExit, setDefaultUri, setDefaultUri, setOwner, setPermission, setTimes, setVerifyChecksum
getConf, setConf
public URI getUri()
FileSystem
getUri
在类中 FileSystem
public void initialize(URI uri, Configuration conf) throws IOException
FileSystem
initialize
在类中 FileSystem
uri
- a uri whose authority section names the host, port, etc.
for this FileSystemconf
- the configurationIOException
@Deprecated public String getName()
getName
在类中 FileSystem
public Path getWorkingDirectory()
FileSystem
getWorkingDirectory
在类中 FileSystem
public void setWorkingDirectory(Path dir)
FileSystem
setWorkingDirectory
在类中 FileSystem
public boolean mkdirs(Path path, FsPermission permission) throws IOException
FileSystem
mkdirs
在类中 FileSystem
IOException
@Deprecated public boolean isDirectory(Path path) throws IOException
isDirectory
在类中 FileSystem
IOException
@Deprecated public boolean isFile(Path path) throws IOException
FileSystem
isFile
在类中 FileSystem
IOException
public FileStatus[] listStatus(Path path) throws IOException
FileSystem
listStatus
在类中 FileSystem
path
- given pathIOException
public FileStatus getFileStatus(Path path) throws IOException
FileSystem
getFileStatus
在类中 FileSystem
path
- The path we want information fromFileNotFoundException
- when the path does not exist;
IOException see specific implementationIOException
public FSDataOutputStream append(Path f, int bufferSize, Progressable progress) throws IOException
append
在类中 FileSystem
f
- the existing file to be appended.bufferSize
- the size of the buffer to be used.progress
- for reporting progress if it is not null.IOException
public FSDataOutputStream create(Path file, FsPermission permission, boolean overwrite, int bufferSize, short replication, long blockSize, Progressable progress) throws IOException
FileSystem
create
在类中 FileSystem
file
- the file name to openoverwrite
- if a file with this name already exists, then if true,
the file will be overwritten, and if false an error will be thrown.bufferSize
- the size of the buffer to be used.replication
- required block replication for the file.IOException
FileSystem.setPermission(Path, FsPermission)
public FSDataInputStream open(Path path, int bufferSize) throws IOException
FileSystem
open
在类中 FileSystem
path
- the file name to openbufferSize
- the size of the buffer to be used.IOException
public boolean rename(Path src, Path dst) throws IOException
FileSystem
rename
在类中 FileSystem
IOException
public boolean delete(Path path, boolean recursive) throws IOException
FileSystem
delete
在类中 FileSystem
path
- the path to delete.recursive
- if path is a directory and set to
true, the directory is deleted else throws an exception. In
case of a file the recursive can be set to either true or false.IOException
@Deprecated public boolean delete(Path path) throws IOException
delete
在类中 FileSystem
IOException
@Deprecated public long getLength(Path path) throws IOException
getLength
在类中 FileSystem
IOException
@Deprecated public short getReplication(Path path) throws IOException
FileSystem
getReplication
在类中 FileSystem
path
- file nameIOException
public short getDefaultReplication()
FileSystem
getDefaultReplication
在类中 FileSystem
public boolean setReplication(Path path, short replication) throws IOException
FileSystem
setReplication
在类中 FileSystem
path
- file namereplication
- new replicationIOException
public long getDefaultBlockSize()
FileSystem
getDefaultBlockSize
在类中 FileSystem
@Deprecated public void lock(Path path, boolean shared) throws IOException
IOException
@Deprecated public void release(Path path) throws IOException
IOException
public BlockLocation[] getFileBlockLocations(FileStatus file, long start, long len) throws IOException
getFileBlockLocations
在类中 FileSystem
IOException
public void copyFromLocalFile(boolean delSrc, Path src, Path dst) throws IOException
FileSystem
copyFromLocalFile
在类中 FileSystem
IOException
public void copyToLocalFile(boolean delSrc, Path src, Path dst) throws IOException
FileSystem
copyToLocalFile
在类中 FileSystem
IOException
public Path startLocalOutput(Path fsOutputFile, Path tmpLocalFile) throws IOException
FileSystem
startLocalOutput
在类中 FileSystem
IOException
public void completeLocalOutput(Path fsOutputFile, Path tmpLocalFile) throws IOException
FileSystem
completeLocalOutput
在类中 FileSystem
IOException
Copyright © 2009 The Apache Software Foundation