org.apache.hadoop.fs
Class LocalFileSystem

java.lang.Object
  extended by org.apache.hadoop.conf.Configured
      extended by org.apache.hadoop.fs.FileSystem
          extended by org.apache.hadoop.fs.FilterFileSystem
              extended by org.apache.hadoop.fs.ChecksumFileSystem
                  extended by org.apache.hadoop.fs.LocalFileSystem
All Implemented Interfaces:
Closeable, Configurable

@InterfaceAudience.Public
@InterfaceStability.Stable
public class LocalFileSystem
extends ChecksumFileSystem

Implement the FileSystem API for the checksumed local filesystem.


Field Summary
 
Fields inherited from class org.apache.hadoop.fs.FilterFileSystem
fs, swapScheme
 
Fields inherited from class org.apache.hadoop.fs.FileSystem
DEFAULT_FS, FS_DEFAULT_NAME_KEY, LOG, SHUTDOWN_HOOK_PRIORITY, statistics
 
Constructor Summary
LocalFileSystem()
           
LocalFileSystem(FileSystem rawLocalFileSystem)
           
 
Method Summary
 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)
          See FileContext.createSymlink(Path, Path, boolean)
 FileStatus getFileLinkStatus(Path f)
          See FileContext.getFileLinkStatus(Path)
 Path getLinkTarget(Path f)
          See FileContext.getLinkTarget(Path)
 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()
          See AbstractFileSystem.supportsSymlinks()
 
Methods inherited from class org.apache.hadoop.fs.ChecksumFileSystem
append, completeLocalOutput, copyToLocalFile, create, createNonRecursive, delete, getApproxChkSumLength, getBytesPerSum, getChecksumFile, getChecksumFileLength, getChecksumLength, getRawFileSystem, isChecksumFile, listLocatedStatus, listStatus, mkdirs, open, rename, setConf, setReplication, setVerifyChecksum, setWriteChecksum, startLocalOutput
 
Methods inherited from class org.apache.hadoop.fs.FilterFileSystem
canonicalizeUri, checkPath, close, concat, copyFromLocalFile, copyFromLocalFile, createNonRecursive, createSnapshot, deleteSnapshot, getAclStatus, getCanonicalUri, getChildFileSystems, getConf, getDefaultBlockSize, getDefaultBlockSize, getDefaultReplication, getDefaultReplication, getFileBlockLocations, getFileChecksum, getFileStatus, getHomeDirectory, getInitialWorkingDirectory, getServerDefaults, getServerDefaults, getStatus, getUri, getUsed, getWorkingDirectory, listCorruptFileBlocks, makeQualified, mkdirs, modifyAclEntries, primitiveCreate, primitiveMkdir, removeAcl, removeAclEntries, removeDefaultAcl, renameSnapshot, resolveLink, resolvePath, setAcl, setOwner, setPermission, setTimes, setWorkingDirectory
 
Methods inherited from class org.apache.hadoop.fs.FileSystem
append, append, areSymlinksEnabled, cancelDeleteOnExit, clearStatistics, closeAll, closeAllForUGI, copyFromLocalFile, copyToLocalFile, copyToLocalFile, create, 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
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Constructor Detail

LocalFileSystem

public LocalFileSystem()

LocalFileSystem

public LocalFileSystem(FileSystem rawLocalFileSystem)
Method Detail

initialize

public void initialize(URI name,
                       Configuration conf)
                throws IOException
Description copied from class: FilterFileSystem
Called after a new FileSystem instance is constructed.

Overrides:
initialize in class FilterFileSystem
Parameters:
name - a uri whose authority section names the host, port, etc. for this FileSystem
conf - the configuration
Throws:
IOException

getScheme

public String getScheme()
Return the protocol scheme for the FileSystem.

Overrides:
getScheme in class FileSystem
Returns:
file

getRaw

public FileSystem getRaw()

pathToFile

public File pathToFile(Path path)
Convert a path to a File.


copyFromLocalFile

public void copyFromLocalFile(boolean delSrc,
                              Path src,
                              Path dst)
                       throws IOException
Description copied from class: FilterFileSystem
The src file is on the local disk. Add it to FS at the given dst name. delSrc indicates if the source should be removed

Overrides:
copyFromLocalFile in class ChecksumFileSystem
Parameters:
delSrc - whether to delete the src
src - path
dst - path
Throws:
IOException

copyToLocalFile

public void copyToLocalFile(boolean delSrc,
                            Path src,
                            Path dst)
                     throws IOException
Description copied from class: ChecksumFileSystem
The src file is under FS, and the dst is on the local disk. Copy it from FS control to the local dst name.

Overrides:
copyToLocalFile in class ChecksumFileSystem
Parameters:
delSrc - whether to delete the src
src - path
dst - path
Throws:
IOException

reportChecksumFailure

public 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.

Overrides:
reportChecksumFailure in class ChecksumFileSystem
Parameters:
p - the file name containing the error
in - the stream open on the file
inPos - the position of the beginning of the bad data in the file
sums - the stream open on the checksum file
sumsPos - the position of the beginning of the bad data in the checksum file
Returns:
if retry is neccessary

supportsSymlinks

public boolean supportsSymlinks()
Description copied from class: FileSystem
See AbstractFileSystem.supportsSymlinks()

Overrides:
supportsSymlinks in class FilterFileSystem

createSymlink

public void createSymlink(Path target,
                          Path link,
                          boolean createParent)
                   throws IOException
Description copied from class: FileSystem
See FileContext.createSymlink(Path, Path, boolean)

Overrides:
createSymlink in class FilterFileSystem
Throws:
IOException

getFileLinkStatus

public FileStatus getFileLinkStatus(Path f)
                             throws IOException
Description copied from class: FileSystem
See FileContext.getFileLinkStatus(Path)

Overrides:
getFileLinkStatus in class FilterFileSystem
Throws:
IOException

getLinkTarget

public Path getLinkTarget(Path f)
                   throws IOException
Description copied from class: FileSystem
See FileContext.getLinkTarget(Path)

Overrides:
getLinkTarget in class FilterFileSystem
Throws:
IOException


Copyright © 2014 Apache Software Foundation. All Rights Reserved.