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

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

Implement the FileSystem API for the checksumed local filesystem.

フィールドのサマリー

クラスから継承されたフィールド org.apache.hadoop.fs.FilterFileSystem

fs, swapScheme

クラスから継承されたフィールド org.apache.hadoop.fs.FileSystem

DEFAULT_FS, FS_DEFAULT_NAME_KEY, LOG, SHUTDOWN_HOOK_PRIORITY, statistics, TRASH_PREFIX

コンストラクタのサマリー

コンストラクタ

コンストラクタと説明
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.
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()

クラスから継承されたメソッド org.apache.hadoop.fs.ChecksumFileSystem

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

クラスから継承されたメソッド org.apache.hadoop.fs.FilterFileSystem

access, canonicalizeUri, checkPath, close, concat, copyFromLocalFile, copyFromLocalFile, create, createNonRecursive, createSnapshot, deleteSnapshot, getAclStatus, getAllStoragePolicies, getCanonicalUri, getChildFileSystems, getConf, getDefaultBlockSize, getDefaultBlockSize, getDefaultReplication, getDefaultReplication, getFileBlockLocations, getFileChecksum, getFileChecksum, getFileStatus, getHomeDirectory, getInitialWorkingDirectory, getServerDefaults, getServerDefaults, getStatus, getStoragePolicy, getTrashRoot, getTrashRoots, getUri, getUsed, getUsed, getWorkingDirectory, getXAttr, getXAttrs, getXAttrs, listCorruptFileBlocks, listLocatedStatus, listStatusIterator, listXAttrs, makeQualified, mkdirs, primitiveCreate, primitiveMkdir, removeXAttr, renameSnapshot, resolveLink, resolvePath, setStoragePolicy, setTimes, setWorkingDirectory, setXAttr, setXAttr, unsetStoragePolicy

クラスから継承されたメソッド 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, createNewFile, createNonRecursive, createSnapshot, delete, deleteOnExit, enableSymlinks, exists, fixRelativePart, get, get, get, getAllStatistics, getBlockSize, getContentSummary, getDefaultPort, getDefaultUri, getFileBlockLocations, getFileSystemClass, getFSofPath, getGlobalStorageStatistics, getLength, getLocal, getName, getNamed, getQuotaUsage, getReplication, getStatistics, getStatistics, getStatus, getStorageStatistics, globStatus, globStatus, isDirectory, isFile, listFiles, listStatus, listStatus, listStatus, mkdirs, moveFromLocalFile, moveFromLocalFile, moveToLocalFile, newInstance, newInstance, newInstance, newInstanceLocal, open, primitiveMkdir, printStatistics, processDeleteOnExit, rename, setDefaultUri, setDefaultUri

クラスから継承されたメソッド java.lang.Object

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

コンストラクタの詳細

LocalFileSystem

public LocalFileSystem()

LocalFileSystem

public LocalFileSystem(FileSystem rawLocalFileSystem)

メソッドの詳細

initialize

public void initialize(URI name,
                       Configuration conf)
                throws IOException

クラスからコピーされた説明: FilterFileSystem

Called after a new FileSystem instance is constructed.

オーバーライド:

initialize クラス内 FilterFileSystem

パラメータ:

name - a uri whose authority section names the host, port, etc. for this FileSystem

conf - the configuration

例外:

IOException

getScheme

public String getScheme()

Return the protocol scheme for the FileSystem.

オーバーライド:

getScheme クラス内 FileSystem

戻り値:

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

クラスからコピーされた説明: 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

パラメータ:

delSrc - whether to delete the src

src - path

dst - path

例外:

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

パラメータ:

delSrc - whether to delete the src

src - path

dst - path

例外:

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 necessary

supportsSymlinks

public boolean supportsSymlinks()

クラスからコピーされた説明: FileSystem

See AbstractFileSystem.supportsSymlinks()

オーバーライド:

supportsSymlinks クラス内 FilterFileSystem

createSymlink

public void createSymlink(Path target,
                          Path link,
                          boolean createParent)
                   throws IOException

クラスからコピーされた説明: FileSystem

See FileContext.createSymlink(Path, Path, boolean)

オーバーライド:

createSymlink クラス内 FilterFileSystem

例外:

IOException

getFileLinkStatus

public FileStatus getFileLinkStatus(Path f)
                             throws IOException

クラスからコピーされた説明: FileSystem

See FileContext.getFileLinkStatus(Path)

オーバーライド:

getFileLinkStatus クラス内 FilterFileSystem

例外:

IOException

getLinkTarget

public Path getLinkTarget(Path f)
                   throws IOException

クラスからコピーされた説明: FileSystem

See FileContext.getLinkTarget(Path)

オーバーライド:

getLinkTarget クラス内 FilterFileSystem

例外:

IOException