@InterfaceAudience.Private @InterfaceStability.Evolving public class FSHDFSUtils extends FSUtils
FSUtils.BlackListDirFilter, FSUtils.DirFilter, FSUtils.FamilyDirFilter, FSUtils.HFileFilter, FSUtils.ReferenceFileFilter, FSUtils.RegionDirFilter, FSUtils.UserTableDirFilter
FULL_RWX_PERMISSIONS, WINDOWS
Constructor and Description |
---|
FSHDFSUtils() |
Modifier and Type | Method and Description |
---|---|
static boolean |
isSameHdfs(Configuration conf,
FileSystem srcFs,
FileSystem desFs) |
void |
recoverFileLease(FileSystem fs,
Path p,
Configuration conf,
CancelableProgressable reporter)
Recover the lease from HDFS, retrying multiple times.
|
checkAccess, checkClusterIdExists, checkDfsSafeMode, checkFileSystemAvailable, checkShortCircuitReadBufferSize, checkVersion, checkVersion, computeHDFSBlocksDistribution, create, create, delete, deleteDirectory, deleteRegionDir, getClusterId, getCurrentFileSystem, getDefaultBlockSize, getDefaultBufferSize, getDefaultReplication, getFamilyDirs, getFilePermissions, getInstance, getLocalTableDirs, getNamespaceDir, getPath, getReferenceFilePaths, getRegionDegreeLocalityMappingFromFS, getRegionDegreeLocalityMappingFromFS, getRegionDirs, getRegionReferenceFileCount, getRootDir, getTableDir, getTableDirs, getTableFragmentation, getTableFragmentation, getTableName, getTableStoreFilePathMap, getTableStoreFilePathMap, getTableStoreFilePathMap, getTableStoreFilePathMap, getTotalTableFragmentation, getVersion, isAppendSupported, isExists, isHDFS, isMajorCompacted, isMatchingTail, isMatchingTail, isRecoveredEdits, isStartingWithPath, listStatus, listStatus, logFileSystemState, metaRegionExists, removeRootPath, renameAndSetModifyTime, setClusterId, setFsDefault, setRootDir, setStoragePolicy, setupShortCircuitRead, setVersion, setVersion, setVersion, validateRootPath, waitOnSafeMode
public static boolean isSameHdfs(Configuration conf, FileSystem srcFs, FileSystem desFs)
conf
- the Configuration of HBasesrcFs
- desFs
- public void recoverFileLease(FileSystem fs, Path p, Configuration conf, CancelableProgressable reporter) throws IOException
recoverFileLease
in class FSUtils
fs
- FileSystem handlep
- Path of file to recover leaseconf
- Configuration handleIOException