@InterfaceAudience.Public @InterfaceStability.Stable public class LocalFileSystem extends ChecksumFileSystem
fs, swapScheme
DEFAULT_FS, FS_DEFAULT_NAME_KEY, LOG, SHUTDOWN_HOOK_PRIORITY, statistics
Constructor and Description |
---|
LocalFileSystem() |
LocalFileSystem(FileSystem rawLocalFileSystem) |
Modifier and Type | Method and Description |
---|---|
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.
|
void |
createSymlink(Path target,
Path link,
boolean createParent)
|
FileStatus |
getFileLinkStatus(Path f)
|
Path |
getLinkTarget(Path f)
|
FileSystem |
getRaw() |
String |
getScheme()
Return the protocol scheme for the FileSystem.
|
void |
initialize(URI name,
Configuration conf)
Called after a new FileSystem instance is constructed.
|
File |
pathToFile(Path path)
Convert a path to a File.
|
boolean |
reportChecksumFailure(Path p,
FSDataInputStream in,
long inPos,
FSDataInputStream sums,
long sumsPos)
Moves files to a bad file directory on the same device, so that their
storage will not be reused.
|
boolean |
supportsSymlinks()
|
append, completeLocalOutput, copyToLocalFile, create, createNonRecursive, delete, getApproxChkSumLength, getBytesPerSum, getChecksumFile, getChecksumFileLength, getChecksumLength, getRawFileSystem, isChecksumFile, listLocatedStatus, listStatus, mkdirs, modifyAclEntries, open, removeAcl, removeAclEntries, removeDefaultAcl, rename, setAcl, setConf, setOwner, setPermission, setReplication, setVerifyChecksum, setWriteChecksum, startLocalOutput, truncate
access, canonicalizeUri, checkPath, close, concat, copyFromLocalFile, copyFromLocalFile, create, createNonRecursive, createSnapshot, deleteSnapshot, getAclStatus, getCanonicalUri, getChildFileSystems, getConf, getDefaultBlockSize, getDefaultBlockSize, getDefaultReplication, getDefaultReplication, getFileBlockLocations, getFileChecksum, getFileChecksum, getFileStatus, getHomeDirectory, getInitialWorkingDirectory, getServerDefaults, getServerDefaults, getStatus, getUri, getUsed, getWorkingDirectory, getXAttr, getXAttrs, getXAttrs, listCorruptFileBlocks, listStatusIterator, listXAttrs, makeQualified, mkdirs, primitiveCreate, primitiveMkdir, removeXAttr, renameSnapshot, resolveLink, resolvePath, setTimes, setWorkingDirectory, setXAttr, setXAttr
append, append, areSymlinksEnabled, cancelDeleteOnExit, clearStatistics, closeAll, closeAllForUGI, copyFromLocalFile, copyToLocalFile, copyToLocalFile, create, create, create, create, create, create, create, create, create, create, create, createNewFile, createNonRecursive, createSnapshot, delete, deleteOnExit, enableSymlinks, exists, fixRelativePart, get, get, get, getAllStatistics, getBlockSize, getContentSummary, getDefaultPort, getDefaultUri, getFileBlockLocations, getFileSystemClass, getFSofPath, getLength, getLocal, getName, getNamed, getReplication, getStatistics, getStatistics, getStatus, globStatus, globStatus, isDirectory, isFile, listFiles, listLocatedStatus, listStatus, listStatus, listStatus, mkdirs, moveFromLocalFile, moveFromLocalFile, moveToLocalFile, newInstance, newInstance, newInstance, newInstanceLocal, open, primitiveMkdir, printStatistics, processDeleteOnExit, rename, setDefaultUri, setDefaultUri
public LocalFileSystem()
public LocalFileSystem(FileSystem rawLocalFileSystem)
public void initialize(URI name, Configuration conf) throws IOException
FilterFileSystem
initialize
in class FilterFileSystem
name
- a uri whose authority section names the host, port, etc.
for this FileSystemconf
- the configurationIOException
public String getScheme()
getScheme
in class FileSystem
file
public FileSystem getRaw()
public File pathToFile(Path path)
public void copyFromLocalFile(boolean delSrc, Path src, Path dst) throws IOException
FilterFileSystem
copyFromLocalFile
in class ChecksumFileSystem
delSrc
- whether to delete the srcsrc
- pathdst
- pathIOException
public void copyToLocalFile(boolean delSrc, Path src, Path dst) throws IOException
ChecksumFileSystem
copyToLocalFile
in class ChecksumFileSystem
delSrc
- whether to delete the srcsrc
- pathdst
- pathIOException
public boolean reportChecksumFailure(Path p, FSDataInputStream in, long inPos, FSDataInputStream sums, long sumsPos)
reportChecksumFailure
in class ChecksumFileSystem
p
- the file name containing the errorin
- the stream open on the fileinPos
- the position of the beginning of the bad data in the filesums
- the stream open on the checksum filesumsPos
- the position of the beginning of the bad data in the checksum filepublic boolean supportsSymlinks()
FileSystem
supportsSymlinks
in class FilterFileSystem
public void createSymlink(Path target, Path link, boolean createParent) throws IOException
FileSystem
createSymlink
in class FilterFileSystem
IOException
public FileStatus getFileLinkStatus(Path f) throws IOException
FileSystem
getFileLinkStatus
in class FilterFileSystem
IOException
public Path getLinkTarget(Path f) throws IOException
FileSystem
getLinkTarget
in class FilterFileSystem
IOException
Copyright © 2016 Apache Software Foundation. All rights reserved.