org.apache.hadoop.hbase.util

Class FSHDFSUtils

java.lang.Object

org.apache.hadoop.hbase.util.CommonFSUtils

org.apache.hadoop.hbase.util.FSUtils

org.apache.hadoop.hbase.util.FSHDFSUtils

@InterfaceAudience.Private
 @InterfaceStability.Evolving
public class FSHDFSUtils
extends FSUtils

Implementation for hdfs

Nested Class Summary

Nested classes/interfaces inherited from class org.apache.hadoop.hbase.util.FSUtils

FSUtils.BlackListDirFilter, FSUtils.DirFilter, FSUtils.FamilyDirFilter, FSUtils.HFileFilter, FSUtils.HFileLinkFilter, FSUtils.ReferenceFileFilter, FSUtils.RegionDirFilter, FSUtils.UserTableDirFilter

Nested classes/interfaces inherited from class org.apache.hadoop.hbase.util.CommonFSUtils

CommonFSUtils.StreamLacksCapabilityException

Field Summary

Fields inherited from class org.apache.hadoop.hbase.util.FSUtils

WINDOWS

Fields inherited from class org.apache.hadoop.hbase.util.CommonFSUtils

FULL_RWX_PERMISSIONS, HBASE_WAL_DIR, UNSAFE_STREAM_CAPABILITY_ENFORCE

Constructor Summary

Constructors

Constructor and Description
FSHDFSUtils()

Method Summary

Modifier and Type	Method and Description
static boolean	isSameHdfs(org.apache.hadoop.conf.Configuration conf, org.apache.hadoop.fs.FileSystem srcFs, org.apache.hadoop.fs.FileSystem desFs)
void	recoverFileLease(org.apache.hadoop.fs.FileSystem fs, org.apache.hadoop.fs.Path p, org.apache.hadoop.conf.Configuration conf, CancelableProgressable reporter) Recover the lease from HDFS, retrying multiple times.

Methods inherited from class org.apache.hadoop.hbase.util.FSUtils

addToHDFSBlocksDistribution, checkAccess, checkClusterIdExists, checkDfsSafeMode, checkFileSystemAvailable, checkShortCircuitReadBufferSize, checkVersion, checkVersion, computeHDFSBlocksDistribution, copyFilesParallel, create, deleteRegionDir, filterFileStatuses, filterFileStatuses, getClusterId, getDFSHedgedReadMetrics, getFamilyDirs, getInstance, getLocalTableDirs, getReferenceFilePaths, getRegionDegreeLocalityMappingFromFS, getRegionDegreeLocalityMappingFromFS, getRegionDirFromRootDir, getRegionDirFromTableDir, getRegionDirs, getRegionReferenceFileCount, getTableDirs, getTableFragmentation, getTableFragmentation, getTableStoreFilePathMap, getTableStoreFilePathMap, getTableStoreFilePathMap, getTableStoreFilePathMap, getTotalTableFragmentation, getVersion, isDistributedFileSystem, isMatchingTail, listStatusWithStatusFilter, metaRegionExists, setClusterId, setupShortCircuitRead, setVersion, setVersion, setVersion, waitOnSafeMode

Methods inherited from class org.apache.hadoop.hbase.util.CommonFSUtils

create, createForWal, createForWal, delete, deleteDirectory, getCurrentFileSystem, getDefaultBlockSize, getDefaultBufferSize, getDefaultReplication, getFilePermissions, getNamespaceDir, getPath, getRootDir, getRootDirFileSystem, getTableDir, getTableName, getWALFileSystem, getWALRegionDir, getWALRootDir, getWALTableDir, getWrongWALRegionDir, hasCapability, isExists, isHDFS, isMatchingTail, isRecoveredEdits, isStartingWithPath, listLocatedStatus, listStatus, listStatus, logFileSystemState, removeWALRootPath, renameAndSetModifyTime, setFsDefault, setRootDir, setStoragePolicy, setWALRootDir, validateRootPath

Methods inherited from class java.lang.Object

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

Constructor Detail

FSHDFSUtils

public FSHDFSUtils()

Method Detail

isSameHdfs

public static boolean isSameHdfs(org.apache.hadoop.conf.Configuration conf,
                                 org.apache.hadoop.fs.FileSystem srcFs,
                                 org.apache.hadoop.fs.FileSystem desFs)

Parameters:

conf - the Configuration of HBase

srcFs -

desFs -

Returns:

Whether srcFs and desFs are on same hdfs or not

recoverFileLease

public void recoverFileLease(org.apache.hadoop.fs.FileSystem fs,
                             org.apache.hadoop.fs.Path p,
                             org.apache.hadoop.conf.Configuration conf,
                             CancelableProgressable reporter)
                      throws IOException

Recover the lease from HDFS, retrying multiple times.

Specified by:

recoverFileLease in class FSUtils

Parameters:

fs - FileSystem handle

p - Path of file to recover lease

conf - Configuration handle

Throws:

IOException