@InterfaceAudience.Public @InterfaceStability.Stable public class RawLocalFileSystem extends FileSystem
DEFAULT_FS, FS_DEFAULT_NAME_KEY, LOG, SHUTDOWN_HOOK_PRIORITY, statistics, TRASH_PREFIX
コンストラクタと説明 |
---|
RawLocalFileSystem() |
修飾子とタイプ | メソッドと説明 |
---|---|
FSDataOutputStream |
append(Path f,
int bufferSize,
Progressable progress)
Append to an existing file (optional operation).
|
void |
close()
No more filesystem operations are needed.
|
void |
completeLocalOutput(Path fsWorkingFile,
Path tmpLocalFile)
Called when we're all done writing to the target.
|
FSDataOutputStream |
create(Path f,
boolean overwrite,
int bufferSize,
short replication,
long blockSize,
Progressable progress)
Create an FSDataOutputStream at the indicated Path with write-progress
reporting.
|
FSDataOutputStream |
create(Path f,
FsPermission permission,
boolean overwrite,
int bufferSize,
short replication,
long blockSize,
Progressable progress)
Create an FSDataOutputStream at the indicated Path with write-progress
reporting.
|
FSDataOutputStream |
createNonRecursive(Path f,
FsPermission permission,
boolean overwrite,
int bufferSize,
short replication,
long blockSize,
Progressable progress)
Opens an FSDataOutputStream at the indicated Path with write-progress
reporting.
|
FSDataOutputStream |
createNonRecursive(Path f,
FsPermission permission,
EnumSet<CreateFlag> flags,
int bufferSize,
short replication,
long blockSize,
Progressable progress)
Opens an FSDataOutputStream at the indicated Path with write-progress
reporting.
|
protected OutputStream |
createOutputStream(Path f,
boolean append) |
protected OutputStream |
createOutputStreamWithMode(Path f,
boolean append,
FsPermission permission) |
void |
createSymlink(Path target,
Path link,
boolean createParent)
|
boolean |
delete(Path p,
boolean recursive)
Delete the given path to a file or directory.
|
FileStatus |
getFileLinkStatus(Path f)
Return a FileStatus representing the given path.
|
FileStatus |
getFileStatus(Path f)
Return a file status object that represents the path.
|
Path |
getHomeDirectory()
Return the current user's home directory in this filesystem.
|
protected Path |
getInitialWorkingDirectory()
Note: with the new FilesContext class, getWorkingDirectory()
will be removed.
|
Path |
getLinkTarget(Path f)
|
FsStatus |
getStatus(Path p)
Returns a status object describing the use and capacity of the
file system.
|
URI |
getUri()
Returns a URI whose scheme and authority identify this FileSystem.
|
Path |
getWorkingDirectory()
Get the current working directory for the given file system
|
boolean |
handleEmptyDstDirectoryOnWindows(Path src,
File srcFile,
Path dst,
File dstFile) |
void |
initialize(URI uri,
Configuration conf)
Called after a new FileSystem instance is constructed.
|
FileStatus[] |
listStatus(Path f)
List the statuses of the files/directories in the given path if the path is
a directory.
|
boolean |
mkdirs(Path f)
Creates the specified directory hierarchy.
|
boolean |
mkdirs(Path f,
FsPermission permission)
Make the given file and all non-existent parents into
directories.
|
protected boolean |
mkOneDir(File p2f) |
protected boolean |
mkOneDirWithMode(Path p,
File p2f,
FsPermission permission) |
void |
moveFromLocalFile(Path src,
Path dst)
The src file is on the local disk.
|
FSDataInputStream |
open(Path f,
int bufferSize)
Opens an FSDataInputStream at the indicated Path.
|
File |
pathToFile(Path path)
Convert a path to a File.
|
boolean |
rename(Path src,
Path dst)
Renames Path src to Path dst.
|
void |
setOwner(Path p,
String username,
String groupname)
Use the command chown to set owner.
|
void |
setPermission(Path p,
FsPermission permission)
Use the command chmod to set permission.
|
void |
setTimes(Path p,
long mtime,
long atime)
Sets the
Path 's last modified time and last access time to
the given valid times. |
void |
setWorkingDirectory(Path newDir)
Set the working directory to the given directory.
|
Path |
startLocalOutput(Path fsOutputFile,
Path tmpLocalFile)
Returns a local File that the user can write output to.
|
boolean |
supportsSymlinks()
|
String |
toString() |
boolean |
truncate(Path f,
long newLength)
Truncate the file in the indicated path to the indicated size.
|
static void |
useStatIfAvailable() |
append, append, areSymlinksEnabled, cancelDeleteOnExit, canonicalizeUri, checkPath, clearStatistics, closeAll, closeAllForUGI, concat, copyFromLocalFile, copyFromLocalFile, copyFromLocalFile, copyFromLocalFile, copyToLocalFile, copyToLocalFile, copyToLocalFile, create, create, create, create, create, create, create, create, create, create, create, createNewFile, createNonRecursive, createSnapshot, createSnapshot, delete, deleteOnExit, deleteSnapshot, enableSymlinks, exists, fixRelativePart, get, get, get, getAclStatus, getAllStatistics, getAllStoragePolicies, getBlockSize, getCanonicalUri, getContentSummary, getDefaultBlockSize, getDefaultBlockSize, getDefaultPort, getDefaultReplication, getDefaultReplication, getDefaultUri, getFileBlockLocations, getFileBlockLocations, getFileChecksum, getFileChecksum, getFileSystemClass, getFSofPath, getGlobalStorageStatistics, getLength, getLocal, getName, getNamed, getQuotaUsage, getReplication, getScheme, getServerDefaults, getServerDefaults, getStatistics, getStatistics, getStatus, getStoragePolicy, getStorageStatistics, getTrashRoot, getTrashRoots, getUsed, getUsed, getXAttr, getXAttrs, getXAttrs, globStatus, globStatus, isDirectory, isFile, listCorruptFileBlocks, listFiles, listLocatedStatus, listLocatedStatus, listStatus, listStatus, listStatus, listStatusIterator, listXAttrs, makeQualified, mkdirs, modifyAclEntries, moveFromLocalFile, moveToLocalFile, newInstance, newInstance, newInstance, newInstanceLocal, open, primitiveCreate, primitiveMkdir, primitiveMkdir, printStatistics, processDeleteOnExit, removeAcl, removeAclEntries, removeDefaultAcl, removeXAttr, rename, renameSnapshot, resolveLink, resolvePath, setAcl, setDefaultUri, setDefaultUri, setReplication, setStoragePolicy, setVerifyChecksum, setWriteChecksum, setXAttr, setXAttr, unsetStoragePolicy
getConf, setConf
public RawLocalFileSystem()
public static void useStatIfAvailable()
public File pathToFile(Path path)
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
public FSDataInputStream open(Path f, int bufferSize) throws IOException
FileSystem
open
クラス内 FileSystem
f
- the file name to openbufferSize
- the size of the buffer to be used.IOException
public FSDataOutputStream append(Path f, int bufferSize, Progressable progress) throws IOException
FileSystem
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 f, boolean overwrite, int bufferSize, short replication, long blockSize, Progressable progress) throws IOException
FileSystem
create
クラス内 FileSystem
f
- 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
protected OutputStream createOutputStream(Path f, boolean append) throws IOException
IOException
protected OutputStream createOutputStreamWithMode(Path f, boolean append, FsPermission permission) throws IOException
IOException
public FSDataOutputStream createNonRecursive(Path f, FsPermission permission, EnumSet<CreateFlag> flags, int bufferSize, short replication, long blockSize, Progressable progress) throws IOException
FileSystem
createNonRecursive
クラス内 FileSystem
f
- the file name to openpermission
- file permissionflags
- CreateFlag
s to use for this stream.bufferSize
- the size of the buffer to be used.replication
- required block replication for the file.blockSize
- block sizeprogress
- the progress reporterIOException
FileSystem.setPermission(Path, FsPermission)
public FSDataOutputStream create(Path f, FsPermission permission, boolean overwrite, int bufferSize, short replication, long blockSize, Progressable progress) throws IOException
FileSystem
create
クラス内 FileSystem
f
- the file name to openpermission
- file permissionoverwrite
- 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.blockSize
- block sizeprogress
- the progress reporterIOException
FileSystem.setPermission(Path, FsPermission)
public FSDataOutputStream createNonRecursive(Path f, FsPermission permission, boolean overwrite, int bufferSize, short replication, long blockSize, Progressable progress) throws IOException
FileSystem
createNonRecursive
クラス内 FileSystem
f
- the file name to openpermission
- file permissionoverwrite
- 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.blockSize
- block sizeprogress
- the progress reporterIOException
FileSystem.setPermission(Path, FsPermission)
public boolean rename(Path src, Path dst) throws IOException
FileSystem
rename
クラス内 FileSystem
src
- path to be renameddst
- new path after renameIOException
- on failurepublic final boolean handleEmptyDstDirectoryOnWindows(Path src, File srcFile, Path dst, File dstFile) throws IOException
IOException
public boolean truncate(Path f, long newLength) throws IOException
FileSystem
truncate
クラス内 FileSystem
f
- The path to the file to be truncatednewLength
- The size the file is to be truncated totrue
if the file has been truncated to the desired
newLength
and is immediately available to be reused for
write operations such as append
, or
false
if a background process of adjusting the length of
the last block has been started, and clients should wait for it to
complete before proceeding with further file updates.IOException
public boolean delete(Path p, boolean recursive) throws IOException
delete
クラス内 FileSystem
p
- the path to deleterecursive
- to delete sub-directoriesIOException
- if p is non-empty and recursive is falsepublic FileStatus[] listStatus(Path f) throws IOException
Does not guarantee to return the List of files/directories status in a
sorted order.
(Note: Returned list is not sorted in any given order,
due to reliance on Java's File.list()
API.)
listStatus
クラス内 FileSystem
f
- given pathFileNotFoundException
- when the path does not exist;
IOException see specific implementationIOException
protected boolean mkOneDir(File p2f) throws IOException
IOException
protected boolean mkOneDirWithMode(Path p, File p2f, FsPermission permission) throws IOException
IOException
public boolean mkdirs(Path f) throws IOException
mkdirs
クラス内 FileSystem
IOException
public boolean mkdirs(Path f, FsPermission permission) throws IOException
FileSystem
mkdirs
クラス内 FileSystem
f
- path to createpermission
- to apply to fIOException
public Path getHomeDirectory()
FileSystem
getHomeDirectory
クラス内 FileSystem
public void setWorkingDirectory(Path newDir)
setWorkingDirectory
クラス内 FileSystem
newDir
- Path of new working directorypublic Path getWorkingDirectory()
FileSystem
getWorkingDirectory
クラス内 FileSystem
protected Path getInitialWorkingDirectory()
FileSystem
getInitialWorkingDirectory
クラス内 FileSystem
public FsStatus getStatus(Path p) throws IOException
FileSystem
getStatus
クラス内 FileSystem
p
- Path for which status should be obtained. null means
the default partition.IOException
- see specific implementationpublic void moveFromLocalFile(Path src, Path dst) throws IOException
FileSystem
moveFromLocalFile
クラス内 FileSystem
src
- pathdst
- pathIOException
public Path startLocalOutput(Path fsOutputFile, Path tmpLocalFile) throws IOException
FileSystem
startLocalOutput
クラス内 FileSystem
fsOutputFile
- path of output filetmpLocalFile
- path of local tmp fileIOException
public void completeLocalOutput(Path fsWorkingFile, Path tmpLocalFile) throws IOException
FileSystem
completeLocalOutput
クラス内 FileSystem
fsWorkingFile
- path of output filetmpLocalFile
- path to local tmp fileIOException
public void close() throws IOException
FileSystem
close
インタフェース内 Closeable
close
インタフェース内 AutoCloseable
close
クラス内 FileSystem
IOException
public FileStatus getFileStatus(Path f) throws IOException
FileSystem
getFileStatus
クラス内 FileSystem
f
- The path we want information fromFileNotFoundException
- when the path does not exist;
IOException see specific implementationIOException
public void setOwner(Path p, String username, String groupname) throws IOException
setOwner
クラス内 FileSystem
p
- The pathusername
- If it is null, the original username remains unchanged.groupname
- If it is null, the original groupname remains unchanged.IOException
public void setPermission(Path p, FsPermission permission) throws IOException
setPermission
クラス内 FileSystem
p
- The pathpermission
- permissionIOException
public void setTimes(Path p, long mtime, long atime) throws IOException
Path
's last modified time and last access time to
the given valid times.setTimes
クラス内 FileSystem
mtime
- the modification time to set (only if no less than zero).atime
- the access time to set (only if no less than zero).p
- The pathIOException
- if setting the times fails.public boolean supportsSymlinks()
FileSystem
supportsSymlinks
クラス内 FileSystem
public void createSymlink(Path target, Path link, boolean createParent) throws IOException
FileSystem
createSymlink
クラス内 FileSystem
IOException
public FileStatus getFileLinkStatus(Path f) throws IOException
getFileLinkStatus
クラス内 FileSystem
IOException
public Path getLinkTarget(Path f) throws IOException
FileSystem
getLinkTarget
クラス内 FileSystem
IOException
Copyright © 2016 Apache Software Foundation. All rights reserved.