@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, unsetStoragePolicygetConf, setConfpublic RawLocalFileSystem()
public static void useStatIfAvailable()
public File pathToFile(Path path)
public URI getUri()
FileSystemgetUri クラス内 FileSystempublic void initialize(URI uri, Configuration conf) throws IOException
FileSysteminitialize クラス内 FileSystemuri - a uri whose authority section names the host, port, etc.
for this FileSystemconf - the configurationIOExceptionpublic FSDataInputStream open(Path f, int bufferSize) throws IOException
FileSystemopen クラス内 FileSystemf - the file name to openbufferSize - the size of the buffer to be used.IOExceptionpublic FSDataOutputStream append(Path f, int bufferSize, Progressable progress) throws IOException
FileSystemappend クラス内 FileSystemf - the existing file to be appended.bufferSize - the size of the buffer to be used.progress - for reporting progress if it is not null.IOExceptionpublic FSDataOutputStream create(Path f, boolean overwrite, int bufferSize, short replication, long blockSize, Progressable progress) throws IOException
FileSystemcreate クラス内 FileSystemf - 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.IOExceptionprotected OutputStream createOutputStream(Path f, boolean append) throws IOException
IOExceptionprotected OutputStream createOutputStreamWithMode(Path f, boolean append, FsPermission permission) throws IOException
IOExceptionpublic FSDataOutputStream createNonRecursive(Path f, FsPermission permission, EnumSet<CreateFlag> flags, int bufferSize, short replication, long blockSize, Progressable progress) throws IOException
FileSystemcreateNonRecursive クラス内 FileSystemf - the file name to openpermission - file permissionflags - CreateFlags 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 reporterIOExceptionFileSystem.setPermission(Path, FsPermission)public FSDataOutputStream create(Path f, FsPermission permission, boolean overwrite, int bufferSize, short replication, long blockSize, Progressable progress) throws IOException
FileSystemcreate クラス内 FileSystemf - 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 reporterIOExceptionFileSystem.setPermission(Path, FsPermission)public FSDataOutputStream createNonRecursive(Path f, FsPermission permission, boolean overwrite, int bufferSize, short replication, long blockSize, Progressable progress) throws IOException
FileSystemcreateNonRecursive クラス内 FileSystemf - 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 reporterIOExceptionFileSystem.setPermission(Path, FsPermission)public boolean rename(Path src, Path dst) throws IOException
FileSystemrename クラス内 FileSystemsrc - path to be renameddst - new path after renameIOException - on failurepublic final boolean handleEmptyDstDirectoryOnWindows(Path src, File srcFile, Path dst, File dstFile) throws IOException
IOExceptionpublic boolean truncate(Path f, long newLength) throws IOException
FileSystemtruncate クラス内 FileSystemf - 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.IOExceptionpublic boolean delete(Path p, boolean recursive) throws IOException
delete クラス内 FileSystemp - 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 クラス内 FileSystemf - given pathFileNotFoundException - when the path does not exist;
IOException see specific implementationIOExceptionprotected boolean mkOneDir(File p2f) throws IOException
IOExceptionprotected boolean mkOneDirWithMode(Path p, File p2f, FsPermission permission) throws IOException
IOExceptionpublic boolean mkdirs(Path f) throws IOException
mkdirs クラス内 FileSystemIOExceptionpublic boolean mkdirs(Path f, FsPermission permission) throws IOException
FileSystemmkdirs クラス内 FileSystemf - path to createpermission - to apply to fIOExceptionpublic Path getHomeDirectory()
FileSystemgetHomeDirectory クラス内 FileSystempublic void setWorkingDirectory(Path newDir)
setWorkingDirectory クラス内 FileSystemnewDir - Path of new working directorypublic Path getWorkingDirectory()
FileSystemgetWorkingDirectory クラス内 FileSystemprotected Path getInitialWorkingDirectory()
FileSystemgetInitialWorkingDirectory クラス内 FileSystempublic FsStatus getStatus(Path p) throws IOException
FileSystemgetStatus クラス内 FileSystemp - Path for which status should be obtained. null means
the default partition.IOException - see specific implementationpublic void moveFromLocalFile(Path src, Path dst) throws IOException
FileSystemmoveFromLocalFile クラス内 FileSystemsrc - pathdst - pathIOExceptionpublic Path startLocalOutput(Path fsOutputFile, Path tmpLocalFile) throws IOException
FileSystemstartLocalOutput クラス内 FileSystemfsOutputFile - path of output filetmpLocalFile - path of local tmp fileIOExceptionpublic void completeLocalOutput(Path fsWorkingFile, Path tmpLocalFile) throws IOException
FileSystemcompleteLocalOutput クラス内 FileSystemfsWorkingFile - path of output filetmpLocalFile - path to local tmp fileIOExceptionpublic void close() throws IOException
FileSystemclose インタフェース内 Closeableclose インタフェース内 AutoCloseableclose クラス内 FileSystemIOExceptionpublic FileStatus getFileStatus(Path f) throws IOException
FileSystemgetFileStatus クラス内 FileSystemf - The path we want information fromFileNotFoundException - when the path does not exist;
IOException see specific implementationIOExceptionpublic void setOwner(Path p, String username, String groupname) throws IOException
setOwner クラス内 FileSystemp - The pathusername - If it is null, the original username remains unchanged.groupname - If it is null, the original groupname remains unchanged.IOExceptionpublic void setPermission(Path p, FsPermission permission) throws IOException
setPermission クラス内 FileSystemp - The pathpermission - permissionIOExceptionpublic 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 クラス内 FileSystemmtime - 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()
FileSystemsupportsSymlinks クラス内 FileSystempublic void createSymlink(Path target, Path link, boolean createParent) throws IOException
FileSystemcreateSymlink クラス内 FileSystemIOExceptionpublic FileStatus getFileLinkStatus(Path f) throws IOException
getFileLinkStatus クラス内 FileSystemIOExceptionpublic Path getLinkTarget(Path f) throws IOException
FileSystemgetLinkTarget クラス内 FileSystemIOExceptionCopyright © 2016 Apache Software Foundation. All rights reserved.