org.apache.hadoop.hbase.util

Class FSUtils

java.lang.Object

org.apache.hadoop.hbase.util.CommonFSUtils

org.apache.hadoop.hbase.util.FSUtils

Direct Known Subclasses:

FSHDFSUtils, FSMapRUtils

@InterfaceAudience.Private
public abstract class FSUtils
extends CommonFSUtils

Utility methods for interacting with the underlying file system.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	FSUtils.BlackListDirFilter Directory filter that doesn't include any of the directories in the specified blacklist
static class	FSUtils.DirFilter A PathFilter that only allows directories.
static class	FSUtils.FamilyDirFilter Filter for all dirs that are legal column family names.
(package private) static class	FSUtils.FileFilter A PathFilter that returns only regular files.
static class	FSUtils.HFileFilter Filter for HFiles that excludes reference files.
static class	FSUtils.HFileLinkFilter Filter for HFileLinks (StoreFiles and HFiles not included).
static class	FSUtils.ReferenceFileFilter
static class	FSUtils.RegionDirFilter Filter for all dirs that don't start with '.'
static class	FSUtils.UserTableDirFilter A PathFilter that returns usertable directories.

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

CommonFSUtils.StreamLacksCapabilityException

Field Summary

Fields

Modifier and Type	Field and Description
private static int	DEFAULT_THREAD_POOLSIZE
private static org.slf4j.Logger	LOG
private static String	THREAD_POOLSIZE
static boolean	WINDOWS Set to true on Windows platforms

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

FULL_RWX_PERMISSIONS, HBASE_WAL_DIR, UNSAFE_STREAM_CAPABILITY_ENFORCE

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	FSUtils()

Method Summary

Modifier and Type	Method and Description
static void	addToHDFSBlocksDistribution(HDFSBlocksDistribution blocksDistribution, org.apache.hadoop.fs.BlockLocation[] blockLocations) Update blocksDistribution with blockLocations
static void	checkAccess(org.apache.hadoop.security.UserGroupInformation ugi, org.apache.hadoop.fs.FileStatus file, org.apache.hadoop.fs.permission.FsAction action) Throw an exception if an action is not permitted by a user on a file.
static boolean	checkClusterIdExists(org.apache.hadoop.fs.FileSystem fs, org.apache.hadoop.fs.Path rootdir, int wait) Checks that a cluster ID file exists in the HBase root directory
static void	checkDfsSafeMode(org.apache.hadoop.conf.Configuration conf) Check whether dfs is in safemode.
static void	checkFileSystemAvailable(org.apache.hadoop.fs.FileSystem fs) Checks to see if the specified file system is available
static void	checkShortCircuitReadBufferSize(org.apache.hadoop.conf.Configuration conf) Check if short circuit read buffer size is set and if not, set it to hbase value.
static void	checkVersion(org.apache.hadoop.fs.FileSystem fs, org.apache.hadoop.fs.Path rootdir, boolean message) Verifies current version of file system
static void	checkVersion(org.apache.hadoop.fs.FileSystem fs, org.apache.hadoop.fs.Path rootdir, boolean message, int wait, int retries) Verifies current version of file system
static HDFSBlocksDistribution	computeHDFSBlocksDistribution(org.apache.hadoop.fs.FileSystem fs, org.apache.hadoop.fs.FileStatus status, long start, long length) Compute HDFS blocks distribution of a given file, or a portion of the file
private static boolean	contains(String[] groups, String user)
static org.apache.hadoop.fs.FSDataOutputStream	create(org.apache.hadoop.conf.Configuration conf, org.apache.hadoop.fs.FileSystem fs, org.apache.hadoop.fs.Path path, org.apache.hadoop.fs.permission.FsPermission perm, InetSocketAddress[] favoredNodes) Create the specified file on the filesystem.
static boolean	deleteRegionDir(org.apache.hadoop.conf.Configuration conf, HRegionInfo hri) Delete the region directory if exists.
static List<org.apache.hadoop.fs.FileStatus>	filterFileStatuses(org.apache.hadoop.fs.FileStatus[] input, FileStatusFilter filter) Filters FileStatuses in an array and returns a list
static List<org.apache.hadoop.fs.FileStatus>	filterFileStatuses(Iterator<org.apache.hadoop.fs.FileStatus> input, FileStatusFilter filter) Filters FileStatuses in an iterator and returns a list
static ClusterId	getClusterId(org.apache.hadoop.fs.FileSystem fs, org.apache.hadoop.fs.Path rootdir) Returns the value of the unique cluster ID stored for this HBase instance.
static org.apache.hadoop.hdfs.DFSHedgedReadMetrics	getDFSHedgedReadMetrics(org.apache.hadoop.conf.Configuration c)
static List<org.apache.hadoop.fs.Path>	getFamilyDirs(org.apache.hadoop.fs.FileSystem fs, org.apache.hadoop.fs.Path regionDir) Given a particular region dir, return all the familydirs inside it
static FSUtils	getInstance(org.apache.hadoop.fs.FileSystem fs, org.apache.hadoop.conf.Configuration conf)
static List<org.apache.hadoop.fs.Path>	getLocalTableDirs(org.apache.hadoop.fs.FileSystem fs, org.apache.hadoop.fs.Path rootdir)
static List<org.apache.hadoop.fs.Path>	getReferenceFilePaths(org.apache.hadoop.fs.FileSystem fs, org.apache.hadoop.fs.Path familyDir)
static Map<String,Map<String,Float>>	getRegionDegreeLocalityMappingFromFS(org.apache.hadoop.conf.Configuration conf) This function is to scan the root path of the file system to get the degree of locality for each region on each of the servers having at least one block of that region.
static Map<String,Map<String,Float>>	getRegionDegreeLocalityMappingFromFS(org.apache.hadoop.conf.Configuration conf, String desiredTable, int threadPoolSize) This function is to scan the root path of the file system to get the degree of locality for each region on each of the servers having at least one block of that region.
static org.apache.hadoop.fs.Path	getRegionDirFromRootDir(org.apache.hadoop.fs.Path rootDir, RegionInfo region)
static org.apache.hadoop.fs.Path	getRegionDirFromTableDir(org.apache.hadoop.fs.Path tableDir, RegionInfo region)
static List<org.apache.hadoop.fs.Path>	getRegionDirs(org.apache.hadoop.fs.FileSystem fs, org.apache.hadoop.fs.Path tableDir) Given a particular table dir, return all the regiondirs inside it, excluding files such as .tableinfo
private static void	getRegionLocalityMappingFromFS(org.apache.hadoop.conf.Configuration conf, String desiredTable, int threadPoolSize, Map<String,String> regionToBestLocalityRSMapping, Map<String,Map<String,Float>> regionDegreeLocalityMapping) This function is to scan the root path of the file system to get either the mapping between the region name and its best locality region server or the degree of locality of each region on each of the servers having at least one block of that region.
static int	getRegionReferenceFileCount(org.apache.hadoop.fs.FileSystem fs, org.apache.hadoop.fs.Path p)
static List<org.apache.hadoop.fs.Path>	getTableDirs(org.apache.hadoop.fs.FileSystem fs, org.apache.hadoop.fs.Path rootdir)
static Map<String,Integer>	getTableFragmentation(org.apache.hadoop.fs.FileSystem fs, org.apache.hadoop.fs.Path hbaseRootDir) Runs through the HBase rootdir and checks how many stores for each table have more than one file in them.
static Map<String,Integer>	getTableFragmentation(HMaster master) Runs through the HBase rootdir and checks how many stores for each table have more than one file in them.
static Map<String,org.apache.hadoop.fs.Path>	getTableStoreFilePathMap(org.apache.hadoop.fs.FileSystem fs, org.apache.hadoop.fs.Path hbaseRootDir) Runs through the HBase rootdir and creates a reverse lookup map for table StoreFile names to the full Path.
static Map<String,org.apache.hadoop.fs.Path>	getTableStoreFilePathMap(org.apache.hadoop.fs.FileSystem fs, org.apache.hadoop.fs.Path hbaseRootDir, org.apache.hadoop.fs.PathFilter sfFilter, ExecutorService executor, HbckErrorReporter errors) Runs through the HBase rootdir and creates a reverse lookup map for table StoreFile names to the full Path.
static Map<String,org.apache.hadoop.fs.Path>	getTableStoreFilePathMap(Map<String,org.apache.hadoop.fs.Path> map, org.apache.hadoop.fs.FileSystem fs, org.apache.hadoop.fs.Path hbaseRootDir, TableName tableName) Runs through the HBase rootdir/tablename and creates a reverse lookup map for table StoreFile names to the full Path.
static Map<String,org.apache.hadoop.fs.Path>	getTableStoreFilePathMap(Map<String,org.apache.hadoop.fs.Path> resultMap, org.apache.hadoop.fs.FileSystem fs, org.apache.hadoop.fs.Path hbaseRootDir, TableName tableName, org.apache.hadoop.fs.PathFilter sfFilter, ExecutorService executor, HbckErrorReporter errors) Runs through the HBase rootdir/tablename and creates a reverse lookup map for table StoreFile names to the full Path.
static int	getTotalTableFragmentation(HMaster master) Returns the total overall fragmentation percentage.
static String	getVersion(org.apache.hadoop.fs.FileSystem fs, org.apache.hadoop.fs.Path rootdir) Verifies current version of file system
static boolean	isDistributedFileSystem(org.apache.hadoop.fs.FileSystem fs)
private static boolean	isInSafeMode(org.apache.hadoop.hdfs.DistributedFileSystem dfs) We use reflection because DistributedFileSystem.setSafeMode( HdfsConstants.SafeModeAction action, boolean isChecked) is not in hadoop 1.1
static boolean	isMatchingTail(org.apache.hadoop.fs.Path pathToSearch, org.apache.hadoop.fs.Path pathTail) Compare path component of the Path URI; e.g.
static List<org.apache.hadoop.fs.FileStatus>	listStatusWithStatusFilter(org.apache.hadoop.fs.FileSystem fs, org.apache.hadoop.fs.Path dir, FileStatusFilter filter) Calls fs.listStatus() and treats FileNotFoundException as non-fatal This accommodates differences between hadoop versions, where hadoop 1 does not throw a FileNotFoundException, and return an empty FileStatus[] while Hadoop 2 will throw FileNotFoundException.
static boolean	metaRegionExists(org.apache.hadoop.fs.FileSystem fs, org.apache.hadoop.fs.Path rootDir) Checks if meta region exists
(package private) static String	parseVersionFrom(byte[] bytes) Parse the content of the ${HBASE_ROOTDIR}/hbase.version file.
abstract void	recoverFileLease(org.apache.hadoop.fs.FileSystem fs, org.apache.hadoop.fs.Path p, org.apache.hadoop.conf.Configuration conf, CancelableProgressable reporter) Recover file lease.
private static void	rewriteAsPb(org.apache.hadoop.fs.FileSystem fs, org.apache.hadoop.fs.Path rootdir, org.apache.hadoop.fs.Path p, ClusterId cid)
static void	setClusterId(org.apache.hadoop.fs.FileSystem fs, org.apache.hadoop.fs.Path rootdir, ClusterId clusterId, int wait) Writes a new unique identifier for this cluster to the "hbase.id" file in the HBase root directory
static void	setupShortCircuitRead(org.apache.hadoop.conf.Configuration conf) Do our short circuit read setup.
static void	setVersion(org.apache.hadoop.fs.FileSystem fs, org.apache.hadoop.fs.Path rootdir) Sets version of file system
static void	setVersion(org.apache.hadoop.fs.FileSystem fs, org.apache.hadoop.fs.Path rootdir, int wait, int retries) Sets version of file system
static void	setVersion(org.apache.hadoop.fs.FileSystem fs, org.apache.hadoop.fs.Path rootdir, String version, int wait, int retries) Sets version of file system
(package private) static byte[]	toVersionByteArray(String version) Create the content to write into the ${HBASE_ROOTDIR}/hbase.version file.
static void	waitOnSafeMode(org.apache.hadoop.conf.Configuration conf, long wait) If DFS, check safe mode and if so, wait until we clear it.

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, setStoragePolicy, setWALRootDir, validateRootPath

Methods inherited from class java.lang.Object

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

Field Detail

LOG

private static final org.slf4j.Logger LOG

THREAD_POOLSIZE

private static final String THREAD_POOLSIZE

See Also:

Constant Field Values

DEFAULT_THREAD_POOLSIZE

private static final int DEFAULT_THREAD_POOLSIZE

See Also:

Constant Field Values

WINDOWS

public static final boolean WINDOWS

Set to true on Windows platforms

Constructor Detail

FSUtils

protected FSUtils()

Method Detail

isDistributedFileSystem

public static boolean isDistributedFileSystem(org.apache.hadoop.fs.FileSystem fs)
                                       throws IOException

Returns:

True is fs is instance of DistributedFileSystem

Throws:

IOException

isMatchingTail

public static boolean isMatchingTail(org.apache.hadoop.fs.Path pathToSearch,
                                     org.apache.hadoop.fs.Path pathTail)

Compare path component of the Path URI; e.g. if hdfs://a/b/c and /a/b/c, it will compare the '/a/b/c' part. If you passed in 'hdfs://a/b/c and b/c, it would return true. Does not consider schema; i.e. if schemas different but path or subpath matches, the two will equate.

Parameters:

pathToSearch - Path we will be trying to match.

pathTail -

Returns:

True if pathTail is tail on the path of pathToSearch

getInstance

public static FSUtils getInstance(org.apache.hadoop.fs.FileSystem fs,
                                  org.apache.hadoop.conf.Configuration conf)

deleteRegionDir

public static boolean deleteRegionDir(org.apache.hadoop.conf.Configuration conf,
                                      HRegionInfo hri)
                               throws IOException

Delete the region directory if exists.

Parameters:

conf -

hri -

Returns:

True if deleted the region directory.

Throws:

IOException

create

public static org.apache.hadoop.fs.FSDataOutputStream create(org.apache.hadoop.conf.Configuration conf,
                                                             org.apache.hadoop.fs.FileSystem fs,
                                                             org.apache.hadoop.fs.Path path,
                                                             org.apache.hadoop.fs.permission.FsPermission perm,
                                                             InetSocketAddress[] favoredNodes)
                                                      throws IOException

Create the specified file on the filesystem. By default, this will:

1. overwrite the file if it exists
2. apply the umask in the configuration (if it is enabled)
3. use the fs configured buffer size (or 4096 if not set)
4. use the configured column family replication or default replication if HColumnDescriptor.DEFAULT_DFS_REPLICATION
5. use the default block size
6. not track progress

Parameters:

conf - configurations

fs - FileSystem on which to write the file

path - Path to the file to write

perm - permissions

favoredNodes -

Returns:

output stream to the created file

Throws:

IOException - if the file cannot be created

checkFileSystemAvailable

public static void checkFileSystemAvailable(org.apache.hadoop.fs.FileSystem fs)
                                     throws IOException

Checks to see if the specified file system is available

Parameters:

fs - filesystem

Throws:

IOException - e

isInSafeMode

private static boolean isInSafeMode(org.apache.hadoop.hdfs.DistributedFileSystem dfs)
                             throws IOException

We use reflection because DistributedFileSystem.setSafeMode( HdfsConstants.SafeModeAction action, boolean isChecked) is not in hadoop 1.1

Parameters:

dfs -

Returns:

whether we're in safe mode

Throws:

IOException

checkDfsSafeMode

public static void checkDfsSafeMode(org.apache.hadoop.conf.Configuration conf)
                             throws IOException

Check whether dfs is in safemode.

Parameters:

conf -

Throws:

IOException

getVersion

public static String getVersion(org.apache.hadoop.fs.FileSystem fs,
                                org.apache.hadoop.fs.Path rootdir)
                         throws IOException,
                                DeserializationException

Verifies current version of file system

Parameters:

fs - filesystem object

rootdir - root hbase directory

Returns:

null if no version file exists, version string otherwise.

Throws:

IOException - e

DeserializationException

parseVersionFrom

static String parseVersionFrom(byte[] bytes)
                        throws DeserializationException

Parse the content of the ${HBASE_ROOTDIR}/hbase.version file.

Parameters:

bytes - The byte content of the hbase.version file.

Returns:

The version found in the file as a String.

Throws:

DeserializationException

toVersionByteArray

static byte[] toVersionByteArray(String version)

Create the content to write into the ${HBASE_ROOTDIR}/hbase.version file.

Parameters:

version - Version to persist

Returns:

Serialized protobuf with version content and a bit of pb magic for a prefix.

checkVersion

public static void checkVersion(org.apache.hadoop.fs.FileSystem fs,
                                org.apache.hadoop.fs.Path rootdir,
                                boolean message)
                         throws IOException,
                                DeserializationException

Verifies current version of file system

Parameters:

fs - file system

rootdir - root directory of HBase installation

message - if true, issues a message on System.out

Throws:

IOException - e

DeserializationException

checkVersion

public static void checkVersion(org.apache.hadoop.fs.FileSystem fs,
                                org.apache.hadoop.fs.Path rootdir,
                                boolean message,
                                int wait,
                                int retries)
                         throws IOException,
                                DeserializationException

Verifies current version of file system

Parameters:

fs - file system

rootdir - root directory of HBase installation

message - if true, issues a message on System.out

wait - wait interval

retries - number of times to retry

Throws:

IOException - e

DeserializationException

setVersion

public static void setVersion(org.apache.hadoop.fs.FileSystem fs,
                              org.apache.hadoop.fs.Path rootdir)
                       throws IOException

Sets version of file system

Parameters:

fs - filesystem object

rootdir - hbase root

Throws:

IOException - e

setVersion

public static void setVersion(org.apache.hadoop.fs.FileSystem fs,
                              org.apache.hadoop.fs.Path rootdir,
                              int wait,
                              int retries)
                       throws IOException

Sets version of file system

Parameters:

fs - filesystem object

rootdir - hbase root

wait - time to wait for retry

retries - number of times to retry before failing

Throws:

IOException - e

setVersion

public static void setVersion(org.apache.hadoop.fs.FileSystem fs,
                              org.apache.hadoop.fs.Path rootdir,
                              String version,
                              int wait,
                              int retries)
                       throws IOException

Sets version of file system

Parameters:

fs - filesystem object

rootdir - hbase root directory

version - version to set

wait - time to wait for retry

retries - number of times to retry before throwing an IOException

Throws:

IOException - e

checkClusterIdExists

public static boolean checkClusterIdExists(org.apache.hadoop.fs.FileSystem fs,
                                           org.apache.hadoop.fs.Path rootdir,
                                           int wait)
                                    throws IOException

Checks that a cluster ID file exists in the HBase root directory

Parameters:

fs - the root directory FileSystem

rootdir - the HBase root directory in HDFS

wait - how long to wait between retries

Returns:

true if the file exists, otherwise false

Throws:

IOException - if checking the FileSystem fails

getClusterId

public static ClusterId getClusterId(org.apache.hadoop.fs.FileSystem fs,
                                     org.apache.hadoop.fs.Path rootdir)
                              throws IOException

Returns the value of the unique cluster ID stored for this HBase instance.

Parameters:

fs - the root directory FileSystem

rootdir - the path to the HBase root directory

Returns:

the unique cluster identifier

Throws:

IOException - if reading the cluster ID file fails

rewriteAsPb

private static void rewriteAsPb(org.apache.hadoop.fs.FileSystem fs,
                                org.apache.hadoop.fs.Path rootdir,
                                org.apache.hadoop.fs.Path p,
                                ClusterId cid)
                         throws IOException

Parameters:

cid -

Throws:

IOException

setClusterId

public static void setClusterId(org.apache.hadoop.fs.FileSystem fs,
                                org.apache.hadoop.fs.Path rootdir,
                                ClusterId clusterId,
                                int wait)
                         throws IOException

Writes a new unique identifier for this cluster to the "hbase.id" file in the HBase root directory

Parameters:

fs - the root directory FileSystem

rootdir - the path to the HBase root directory

clusterId - the unique identifier to store

wait - how long (in milliseconds) to wait between retries

Throws:

IOException - if writing to the FileSystem fails and no wait value

waitOnSafeMode

public static void waitOnSafeMode(org.apache.hadoop.conf.Configuration conf,
                                  long wait)
                           throws IOException

If DFS, check safe mode and if so, wait until we clear it.

Parameters:

conf - configuration

wait - Sleep between retries

Throws:

IOException - e

metaRegionExists

public static boolean metaRegionExists(org.apache.hadoop.fs.FileSystem fs,
                                       org.apache.hadoop.fs.Path rootDir)
                                throws IOException

Checks if meta region exists

Parameters:

fs - file system

rootDir - root directory of HBase installation

Returns:

true if exists

Throws:

IOException

computeHDFSBlocksDistribution

public static HDFSBlocksDistribution computeHDFSBlocksDistribution(org.apache.hadoop.fs.FileSystem fs,
                                                                   org.apache.hadoop.fs.FileStatus status,
                                                                   long start,
                                                                   long length)
                                                            throws IOException

Compute HDFS blocks distribution of a given file, or a portion of the file

Parameters:

fs - file system

status - file status of the file

start - start position of the portion

length - length of the portion

Returns:

The HDFS blocks distribution

Throws:

IOException

addToHDFSBlocksDistribution

public static void addToHDFSBlocksDistribution(HDFSBlocksDistribution blocksDistribution,
                                               org.apache.hadoop.fs.BlockLocation[] blockLocations)
                                        throws IOException

Update blocksDistribution with blockLocations

Parameters:

blocksDistribution - the hdfs blocks distribution

blockLocations - an array containing block location

Throws:

IOException

getTotalTableFragmentation

public static int getTotalTableFragmentation(HMaster master)
                                      throws IOException

Returns the total overall fragmentation percentage. Includes hbase:meta and -ROOT- as well.

Parameters:

master - The master defining the HBase root and file system.

Returns:

A map for each table and its percentage.

Throws:

IOException - When scanning the directory fails.

getTableFragmentation

public static Map<String,Integer> getTableFragmentation(HMaster master)
                                                 throws IOException

Runs through the HBase rootdir and checks how many stores for each table have more than one file in them. Checks -ROOT- and hbase:meta too. The total percentage across all tables is stored under the special key "-TOTAL-".

Parameters:

master - The master defining the HBase root and file system.

Returns:

A map for each table and its percentage.

Throws:

IOException - When scanning the directory fails.

getTableFragmentation

public static Map<String,Integer> getTableFragmentation(org.apache.hadoop.fs.FileSystem fs,
                                                        org.apache.hadoop.fs.Path hbaseRootDir)
                                                 throws IOException

Runs through the HBase rootdir and checks how many stores for each table have more than one file in them. Checks -ROOT- and hbase:meta too. The total percentage across all tables is stored under the special key "-TOTAL-".

Parameters:

fs - The file system to use.

hbaseRootDir - The root directory to scan.

Returns:

A map for each table and its percentage.

Throws:

IOException - When scanning the directory fails.

recoverFileLease

public abstract 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 file lease. Used when a file might be suspect to be had been left open by another process.

Parameters:

fs - FileSystem handle

p - Path of file to recover lease

conf - Configuration handle

Throws:

IOException

getTableDirs

public static List<org.apache.hadoop.fs.Path> getTableDirs(org.apache.hadoop.fs.FileSystem fs,
                                                           org.apache.hadoop.fs.Path rootdir)
                                                    throws IOException

Throws:

IOException

getLocalTableDirs

public static List<org.apache.hadoop.fs.Path> getLocalTableDirs(org.apache.hadoop.fs.FileSystem fs,
                                                                org.apache.hadoop.fs.Path rootdir)
                                                         throws IOException

Parameters:

fs -

rootdir -

Returns:

All the table directories under rootdir. Ignore non table hbase folders such as .logs, .oldlogs, .corrupt folders.

Throws:

IOException

getRegionDirs

public static List<org.apache.hadoop.fs.Path> getRegionDirs(org.apache.hadoop.fs.FileSystem fs,
                                                            org.apache.hadoop.fs.Path tableDir)
                                                     throws IOException

Given a particular table dir, return all the regiondirs inside it, excluding files such as .tableinfo

Parameters:

fs - A file system for the Path

tableDir - Path to a specific table directory <hbase.rootdir>/<tabledir>

Returns:

List of paths to valid region directories in table dir.

Throws:

IOException

getRegionDirFromRootDir

public static org.apache.hadoop.fs.Path getRegionDirFromRootDir(org.apache.hadoop.fs.Path rootDir,
                                                                RegionInfo region)

getRegionDirFromTableDir

public static org.apache.hadoop.fs.Path getRegionDirFromTableDir(org.apache.hadoop.fs.Path tableDir,
                                                                 RegionInfo region)

getFamilyDirs

public static List<org.apache.hadoop.fs.Path> getFamilyDirs(org.apache.hadoop.fs.FileSystem fs,
                                                            org.apache.hadoop.fs.Path regionDir)
                                                     throws IOException

Given a particular region dir, return all the familydirs inside it

Parameters:

fs - A file system for the Path

regionDir - Path to a specific region directory

Returns:

List of paths to valid family directories in region dir.

Throws:

IOException

getReferenceFilePaths

public static List<org.apache.hadoop.fs.Path> getReferenceFilePaths(org.apache.hadoop.fs.FileSystem fs,
                                                                    org.apache.hadoop.fs.Path familyDir)
                                                             throws IOException

Throws:

IOException

getTableStoreFilePathMap

public static Map<String,org.apache.hadoop.fs.Path> getTableStoreFilePathMap(Map<String,org.apache.hadoop.fs.Path> map,
                                                                             org.apache.hadoop.fs.FileSystem fs,
                                                                             org.apache.hadoop.fs.Path hbaseRootDir,
                                                                             TableName tableName)
                                                                      throws IOException,
                                                                             InterruptedException

Runs through the HBase rootdir/tablename and creates a reverse lookup map for table StoreFile names to the full Path.
Example...
Key = 3944417774205889744
Value = hdfs://localhost:51169/user/userid/-ROOT-/70236052/info/3944417774205889744

Parameters:

map - map to add values. If null, this method will create and populate one to return

fs - The file system to use.

hbaseRootDir - The root directory to scan.

tableName - name of the table to scan.

Returns:

Map keyed by StoreFile name with a value of the full Path.

Throws:

IOException - When scanning the directory fails.

InterruptedException

getTableStoreFilePathMap

public static Map<String,org.apache.hadoop.fs.Path> getTableStoreFilePathMap(Map<String,org.apache.hadoop.fs.Path> resultMap,
                                                                             org.apache.hadoop.fs.FileSystem fs,
                                                                             org.apache.hadoop.fs.Path hbaseRootDir,
                                                                             TableName tableName,
                                                                             org.apache.hadoop.fs.PathFilter sfFilter,
                                                                             ExecutorService executor,
                                                                             HbckErrorReporter errors)
                                                                      throws IOException,
                                                                             InterruptedException

Runs through the HBase rootdir/tablename and creates a reverse lookup map for table StoreFile names to the full Path. Note that because this method can be called on a 'live' HBase system that we will skip files that no longer exist by the time we traverse them and similarly the user of the result needs to consider that some entries in this map may not exist by the time this call completes.
Example...
Key = 3944417774205889744
Value = hdfs://localhost:51169/user/userid/-ROOT-/70236052/info/3944417774205889744

Parameters:

resultMap - map to add values. If null, this method will create and populate one to return

fs - The file system to use.

hbaseRootDir - The root directory to scan.

tableName - name of the table to scan.

sfFilter - optional path filter to apply to store files

executor - optional executor service to parallelize this operation

errors - ErrorReporter instance or null

Returns:

Map keyed by StoreFile name with a value of the full Path.

Throws:

IOException - When scanning the directory fails.

InterruptedException

getRegionReferenceFileCount

public static int getRegionReferenceFileCount(org.apache.hadoop.fs.FileSystem fs,
                                              org.apache.hadoop.fs.Path p)

getTableStoreFilePathMap

public static Map<String,org.apache.hadoop.fs.Path> getTableStoreFilePathMap(org.apache.hadoop.fs.FileSystem fs,
                                                                             org.apache.hadoop.fs.Path hbaseRootDir)
                                                                      throws IOException,
                                                                             InterruptedException

Runs through the HBase rootdir and creates a reverse lookup map for table StoreFile names to the full Path.
Example...
Key = 3944417774205889744
Value = hdfs://localhost:51169/user/userid/-ROOT-/70236052/info/3944417774205889744

Parameters:

fs - The file system to use.

hbaseRootDir - The root directory to scan.

Returns:

Map keyed by StoreFile name with a value of the full Path.

Throws:

IOException - When scanning the directory fails.

InterruptedException

getTableStoreFilePathMap

public static Map<String,org.apache.hadoop.fs.Path> getTableStoreFilePathMap(org.apache.hadoop.fs.FileSystem fs,
                                                                             org.apache.hadoop.fs.Path hbaseRootDir,
                                                                             org.apache.hadoop.fs.PathFilter sfFilter,
                                                                             ExecutorService executor,
                                                                             HbckErrorReporter errors)
                                                                      throws IOException,
                                                                             InterruptedException

Runs through the HBase rootdir and creates a reverse lookup map for table StoreFile names to the full Path.
Example...
Key = 3944417774205889744
Value = hdfs://localhost:51169/user/userid/-ROOT-/70236052/info/3944417774205889744

Parameters:

fs - The file system to use.

hbaseRootDir - The root directory to scan.

sfFilter - optional path filter to apply to store files

executor - optional executor service to parallelize this operation

errors - ErrorReporter instance or null

Returns:

Map keyed by StoreFile name with a value of the full Path.

Throws:

IOException - When scanning the directory fails.

InterruptedException

filterFileStatuses

public static List<org.apache.hadoop.fs.FileStatus> filterFileStatuses(org.apache.hadoop.fs.FileStatus[] input,
                                                                       FileStatusFilter filter)

Filters FileStatuses in an array and returns a list

Parameters:

input - An array of FileStatuses

filter - A required filter to filter the array

Returns:

A list of FileStatuses

filterFileStatuses

public static List<org.apache.hadoop.fs.FileStatus> filterFileStatuses(Iterator<org.apache.hadoop.fs.FileStatus> input,
                                                                       FileStatusFilter filter)

Filters FileStatuses in an iterator and returns a list

Parameters:

input - An iterator of FileStatuses

filter - A required filter to filter the array

Returns:

A list of FileStatuses

listStatusWithStatusFilter

public static List<org.apache.hadoop.fs.FileStatus> listStatusWithStatusFilter(org.apache.hadoop.fs.FileSystem fs,
                                                                               org.apache.hadoop.fs.Path dir,
                                                                               FileStatusFilter filter)
                                                                        throws IOException

Calls fs.listStatus() and treats FileNotFoundException as non-fatal This accommodates differences between hadoop versions, where hadoop 1 does not throw a FileNotFoundException, and return an empty FileStatus[] while Hadoop 2 will throw FileNotFoundException.

Parameters:

fs - file system

dir - directory

filter - file status filter

Returns:

null if dir is empty or doesn't exist, otherwise FileStatus list

Throws:

IOException

checkAccess

public static void checkAccess(org.apache.hadoop.security.UserGroupInformation ugi,
                               org.apache.hadoop.fs.FileStatus file,
                               org.apache.hadoop.fs.permission.FsAction action)
                        throws AccessDeniedException

Throw an exception if an action is not permitted by a user on a file.

Parameters:

ugi - the user

file - the file

action - the action

Throws:

AccessDeniedException

contains

private static boolean contains(String[] groups,
                                String user)

getRegionDegreeLocalityMappingFromFS

public static Map<String,Map<String,Float>> getRegionDegreeLocalityMappingFromFS(org.apache.hadoop.conf.Configuration conf)
                                                                          throws IOException

This function is to scan the root path of the file system to get the degree of locality for each region on each of the servers having at least one block of that region. This is used by the tool RegionPlacementMaintainer

Parameters:

conf - the configuration to use

Returns:

the mapping from region encoded name to a map of server names to locality fraction

Throws:

IOException - in case of file system errors or interrupts

getRegionDegreeLocalityMappingFromFS

public static Map<String,Map<String,Float>> getRegionDegreeLocalityMappingFromFS(org.apache.hadoop.conf.Configuration conf,
                                                                                 String desiredTable,
                                                                                 int threadPoolSize)
                                                                          throws IOException

This function is to scan the root path of the file system to get the degree of locality for each region on each of the servers having at least one block of that region.

Parameters:

conf - the configuration to use

desiredTable - the table you wish to scan locality for

threadPoolSize - the thread pool size to use

Returns:

the mapping from region encoded name to a map of server names to locality fraction

Throws:

IOException - in case of file system errors or interrupts

getRegionLocalityMappingFromFS

private static void getRegionLocalityMappingFromFS(org.apache.hadoop.conf.Configuration conf,
                                                   String desiredTable,
                                                   int threadPoolSize,
                                                   Map<String,String> regionToBestLocalityRSMapping,
                                                   Map<String,Map<String,Float>> regionDegreeLocalityMapping)
                                            throws IOException

This function is to scan the root path of the file system to get either the mapping between the region name and its best locality region server or the degree of locality of each region on each of the servers having at least one block of that region. The output map parameters are both optional.

Parameters:

conf - the configuration to use

desiredTable - the table you wish to scan locality for

threadPoolSize - the thread pool size to use

regionToBestLocalityRSMapping - the map into which to put the best locality mapping or null

regionDegreeLocalityMapping - the map into which to put the locality degree mapping or null, must be a thread-safe implementation

Throws:

IOException - in case of file system errors or interrupts

setupShortCircuitRead

public static void setupShortCircuitRead(org.apache.hadoop.conf.Configuration conf)

Do our short circuit read setup. Checks buffer size to use and whether to do checksumming in hbase or hdfs.

Parameters:

conf -

checkShortCircuitReadBufferSize

public static void checkShortCircuitReadBufferSize(org.apache.hadoop.conf.Configuration conf)

Check if short circuit read buffer size is set and if not, set it to hbase value.

Parameters:

conf -

getDFSHedgedReadMetrics

public static org.apache.hadoop.hdfs.DFSHedgedReadMetrics getDFSHedgedReadMetrics(org.apache.hadoop.conf.Configuration c)
                                                                           throws IOException

Parameters:

c -

Returns:

The DFSClient DFSHedgedReadMetrics instance or null if can't be found or not on hdfs.

Throws:

IOException