Package org.apache.hadoop.hbase.master

Class MasterFileSystem

java.lang.Object

org.apache.hadoop.hbase.master.MasterFileSystem

@Private
public class MasterFileSystem
extends Object

This class abstracts a bunch of operations the HMaster needs to interact with the underlying file system like creating the initial layout, checking file system status, etc.

Field Summary

Fields

Modifier and Type	Field	Description
private ActiveClusterSuffix	activeClusterSuffix
private ClusterId	clusterId
private final org.apache.hadoop.conf.Configuration	conf
private final org.apache.hadoop.fs.FileSystem	fs
static final String	HBASE_DIR_PERMS	Parameter name for HBase instance root directory permission
static final String	HBASE_WAL_DIR_PERMS	Parameter name for HBase WAL directory permission
private final org.apache.hadoop.fs.permission.FsPermission	HiddenDirPerms
private boolean	isSecurityEnabled
private static final org.slf4j.Logger	LOG
private final org.apache.hadoop.fs.Path	rootdir
private final org.apache.hadoop.fs.permission.FsPermission	secureRootFilePerms
private final org.apache.hadoop.fs.permission.FsPermission	secureRootSubDirPerms
private final org.apache.hadoop.fs.Path	tempdir
private final org.apache.hadoop.fs.FileSystem	walFs
private final org.apache.hadoop.fs.Path	walRootDir

Constructor Summary

Constructors

Constructor	Description
MasterFileSystem(org.apache.hadoop.conf.Configuration conf)

Method Summary

Modifier and Type	Method	Description
private void	checkRootDir(org.apache.hadoop.fs.Path rd, org.apache.hadoop.conf.Configuration c, org.apache.hadoop.fs.FileSystem fs)	Get the rootdir.
private void	checkStagingDir()	Check permissions for bulk load staging directory.
private void	checkSubDir(org.apache.hadoop.fs.Path p, String dirPermsConfName)	Make sure the directories under rootDir have good permissions.
(package private) void	checkTempDir(org.apache.hadoop.fs.Path tmpdir, org.apache.hadoop.conf.Configuration c, org.apache.hadoop.fs.FileSystem fs)	Make sure the hbase temp directory exists and is empty.
private void	createInitialFileSystemLayout()	Create initial layout in filesystem.
void	deleteFamilyFromFS(org.apache.hadoop.fs.Path rootDir, RegionInfo region, byte[] familyName)
void	deleteFamilyFromFS(RegionInfo region, byte[] familyName)
ActiveClusterSuffix	getActiveClusterSuffix()
ClusterId	getClusterId()	Returns The unique identifier generated for this cluster
org.apache.hadoop.conf.Configuration	getConfiguration()
org.apache.hadoop.fs.FileSystem	getFileSystem()
org.apache.hadoop.fs.Path	getRegionDir(RegionInfo region)	Returns the directory for a give region.
org.apache.hadoop.fs.Path	getRootDir()	Returns HBase root dir.
org.apache.hadoop.fs.Path	getTempDir()	Returns HBase temp dir.
org.apache.hadoop.fs.FileSystem	getWALFileSystem()
org.apache.hadoop.fs.Path	getWALRootDir()	Returns HBase root log dir.
void	logFileSystemState(org.slf4j.Logger log)
private void	negotiateActiveClusterSuffixFile(long wait)
void	stop()

Methods inherited from class java.lang.Object

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

Field Details

LOG

private static final org.slf4j.Logger LOG

HBASE_DIR_PERMS

public static final String HBASE_DIR_PERMS

Parameter name for HBase instance root directory permission

See Also:

• Constant Field Values

HBASE_WAL_DIR_PERMS

public static final String HBASE_WAL_DIR_PERMS

Parameter name for HBase WAL directory permission

See Also:

• Constant Field Values

conf

private final org.apache.hadoop.conf.Configuration conf

clusterId

private ClusterId clusterId

activeClusterSuffix

private ActiveClusterSuffix activeClusterSuffix

fs

private final org.apache.hadoop.fs.FileSystem fs

walFs

private final org.apache.hadoop.fs.FileSystem walFs

rootdir

private final org.apache.hadoop.fs.Path rootdir

tempdir

private final org.apache.hadoop.fs.Path tempdir

walRootDir

private final org.apache.hadoop.fs.Path walRootDir

secureRootSubDirPerms

private final org.apache.hadoop.fs.permission.FsPermission secureRootSubDirPerms

secureRootFilePerms

private final org.apache.hadoop.fs.permission.FsPermission secureRootFilePerms

HiddenDirPerms

private final org.apache.hadoop.fs.permission.FsPermission HiddenDirPerms

isSecurityEnabled

private boolean isSecurityEnabled

Constructor Details

MasterFileSystem

public MasterFileSystem(org.apache.hadoop.conf.Configuration conf)
                 throws IOException

Throws:

IOException

Method Details

createInitialFileSystemLayout

private void createInitialFileSystemLayout()
                                    throws IOException

Create initial layout in filesystem.

1. Check if the meta region exists and is readable, if not create it. Create hbase.version and the hbase:meta directory if not one.

Idempotent.

Throws:

IOException

getFileSystem

public org.apache.hadoop.fs.FileSystem getFileSystem()

getWALFileSystem

public org.apache.hadoop.fs.FileSystem getWALFileSystem()

getConfiguration

public org.apache.hadoop.conf.Configuration getConfiguration()

getRootDir

public org.apache.hadoop.fs.Path getRootDir()

Returns HBase root dir.

getWALRootDir

public org.apache.hadoop.fs.Path getWALRootDir()

Returns HBase root log dir.

getRegionDir

public org.apache.hadoop.fs.Path getRegionDir(RegionInfo region)

Returns the directory for a give region.

getTempDir

public org.apache.hadoop.fs.Path getTempDir()

Returns HBase temp dir.

getClusterId

public ClusterId getClusterId()

Returns The unique identifier generated for this cluster

checkRootDir

private void checkRootDir(org.apache.hadoop.fs.Path rd,
 org.apache.hadoop.conf.Configuration c,
 org.apache.hadoop.fs.FileSystem fs)
                   throws IOException

Get the rootdir. Make sure its wholesome and exists before returning.

Throws:

IOException

checkTempDir

void checkTempDir(org.apache.hadoop.fs.Path tmpdir,
 org.apache.hadoop.conf.Configuration c,
 org.apache.hadoop.fs.FileSystem fs)
           throws IOException

Make sure the hbase temp directory exists and is empty. NOTE that this method is only executed once just after the master becomes the active one.

Throws:

IOException

checkSubDir

private void checkSubDir(org.apache.hadoop.fs.Path p,
 String dirPermsConfName)
                  throws IOException

Make sure the directories under rootDir have good permissions. Create if necessary.

Throws:

IOException

checkStagingDir

private void checkStagingDir()
                      throws IOException

Check permissions for bulk load staging directory. This directory has special hidden permissions. Create it if necessary.

Throws:

IOException

deleteFamilyFromFS

public void deleteFamilyFromFS(RegionInfo region,
 byte[] familyName)
                        throws IOException

Throws:

IOException

deleteFamilyFromFS

public void deleteFamilyFromFS(org.apache.hadoop.fs.Path rootDir,
 RegionInfo region,
 byte[] familyName)
                        throws IOException

Throws:

IOException

stop

public void stop()

logFileSystemState

public void logFileSystemState(org.slf4j.Logger log)
                        throws IOException

Throws:

IOException

negotiateActiveClusterSuffixFile

private void negotiateActiveClusterSuffixFile(long wait)
                                       throws IOException

Throws:

IOException

getActiveClusterSuffix

public ActiveClusterSuffix getActiveClusterSuffix()