org.apache.hadoop.fs

类 LocalFileSystem

java.lang.Object

org.apache.hadoop.conf.Configured

org.apache.hadoop.fs.FileSystem

org.apache.hadoop.fs.FilterFileSystem

org.apache.hadoop.fs.ChecksumFileSystem

org.apache.hadoop.fs.LocalFileSystem

所有已实现的接口:

Closeable, AutoCloseable, Configurable

public class LocalFileSystem
extends ChecksumFileSystem

Implement the FileSystem API for the checksumed local filesystem.

嵌套类概要

从类继承的嵌套类/接口 org.apache.hadoop.fs.FileSystem

FileSystem.Statistics

字段概要

从类继承的字段 org.apache.hadoop.fs.FilterFileSystem

fs

从类继承的字段 org.apache.hadoop.fs.FileSystem

FS_DEFAULT_NAME_KEY, LOG, statistics

构造器概要

构造器

构造器和说明
LocalFileSystem()
LocalFileSystem(FileSystem rawLocalFileSystem)

方法概要

方法

限定符和类型	方法和说明
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.
boolean	exists(Path f) Get file status.
FileSystem	getRaw()
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.

从类继承的方法 org.apache.hadoop.fs.ChecksumFileSystem

append, completeLocalOutput, copyToLocalFile, create, createNonRecursive, delete, getApproxChkSumLength, getBytesPerSum, getChecksumFile, getChecksumFileLength, getChecksumLength, getRawFileSystem, isChecksumFile, listStatus, mkdirs, open, rename, setConf, setReplication, setVerifyChecksum, startLocalOutput

从类继承的方法 org.apache.hadoop.fs.FilterFileSystem

checkPath, close, concat, delete, getCanonicalServiceName, getConf, getDefaultBlockSize, getDefaultReplication, getFileBlockLocations, getFileChecksum, getFileStatus, getHomeDirectory, getName, getUri, getWorkingDirectory, initialize, makeQualified, mkdirs, setOwner, setPermission, setWorkingDirectory

从类继承的方法 org.apache.hadoop.fs.FileSystem

addFileSystemForTesting, append, append, clearStatistics, closeAll, closeAllForUGI, copyFromLocalFile, copyFromLocalFile, copyFromLocalFile, copyToLocalFile, create, create, create, create, create, create, create, create, create, create, createNewFile, createNonRecursive, deleteOnExit, get, get, get, getAllStatistics, getBlockSize, getCacheSize, getCanonicalUri, getContentSummary, getDefaultBlockSize, getDefaultPort, getDefaultReplication, getDefaultUri, getDelegationToken, getLength, getLocal, getNamed, getReplication, getStatistics, getStatistics, getUsed, globStatus, globStatus, isDirectory, isFile, listStatus, listStatus, listStatus, mkdirs, moveFromLocalFile, moveFromLocalFile, moveToLocalFile, open, printStatistics, processDeleteOnExit, setDefaultUri, setDefaultUri, setTimes

从类继承的方法 java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

构造器详细资料

LocalFileSystem

public LocalFileSystem()

LocalFileSystem

public LocalFileSystem(FileSystem rawLocalFileSystem)

方法详细资料

getRaw

public FileSystem getRaw()

exists

public boolean exists(Path f)
               throws IOException

Get file status.

覆盖:

exists 在类中 FileSystem

参数:

f - source file

抛出:

IOException

pathToFile

public File pathToFile(Path path)

Convert a path to a File.

copyFromLocalFile

public void copyFromLocalFile(boolean delSrc,
                     Path src,
                     Path dst)
                       throws IOException

从类复制的说明: 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

覆盖:

copyFromLocalFile 在类中 ChecksumFileSystem

抛出:

IOException

copyToLocalFile

public void copyToLocalFile(boolean delSrc,
                   Path src,
                   Path dst)
                     throws IOException

从类复制的说明: 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.

覆盖:

copyToLocalFile 在类中 ChecksumFileSystem

抛出:

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.

覆盖:

reportChecksumFailure 在类中 ChecksumFileSystem

参数:

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

返回:

if retry is neccessary