org.apache.hadoop.hbase.master.region

Class MasterRegion

java.lang.Object

org.apache.hadoop.hbase.master.region.MasterRegion

@InterfaceAudience.Private
public final class MasterRegion
extends Object

A region that stores data in a separated directory, which can be used to store master local data.

FileSystem layout:

 hbase
   |
   --<region dir>
       |
       --data
       |  |
       |  --/<ns>/<table>/<encoded-region-name> <---- The region data
       |      |
       |      --replay <---- The edits to replay
       |
       --WALs
          |
          --<master-server-name> <---- The WAL dir for active master
          |
          --<master-server-name>-dead <---- The WAL dir for dead master
 

Notice that, you can use different root file system and WAL file system. Then the above directory will be on two file systems, the root file system will have the data directory while the WAL filesystem will have the WALs directory. The archived HFile will be moved to the global HFile archived directory with the MasterRegionParams.archivedWalSuffix() suffix. The archived WAL will be moved to the global WAL archived directory with the MasterRegionParams.archivedHFileSuffix() suffix.

Field Summary

Fields

Modifier and Type	Field and Description
private static String	DEAD_WAL_DIR_SUFFIX
(package private) MasterRegionFlusherAndCompactor	flusherAndCompactor
private static org.slf4j.Logger	LOG
(package private) HRegion	region
private static int	REGION_ID
private static String	REPLAY_EDITS_DIR
private WALFactory	walFactory
private MasterRegionWALRoller	walRoller

Constructor Summary

Constructors

Modifier	Constructor and Description
private	MasterRegion(HRegion region, WALFactory walFactory, MasterRegionFlusherAndCompactor flusherAndCompactor, MasterRegionWALRoller walRoller)

Method Summary

Modifier and Type	Method and Description
private static HRegion	bootstrap(org.apache.hadoop.conf.Configuration conf, TableDescriptor td, org.apache.hadoop.fs.FileSystem fs, org.apache.hadoop.fs.Path rootDir, org.apache.hadoop.fs.FileSystem walFs, org.apache.hadoop.fs.Path walRootDir, WALFactory walFactory, MasterRegionWALRoller walRoller, String serverName)
void	close(boolean abort)
private void	closeRegion(boolean abort)
static MasterRegion	create(MasterRegionParams params)
private static WAL	createWAL(WALFactory walFactory, MasterRegionWALRoller walRoller, String serverName, org.apache.hadoop.fs.FileSystem walFs, org.apache.hadoop.fs.Path walRootDir, RegionInfo regionInfo)
HRegion.FlushResult	flush(boolean force)
Result	get(Get get)
RegionScanner	getScanner(Scan scan)
private static HRegion	open(org.apache.hadoop.conf.Configuration conf, TableDescriptor td, org.apache.hadoop.fs.FileSystem fs, org.apache.hadoop.fs.Path rootDir, org.apache.hadoop.fs.FileSystem walFs, org.apache.hadoop.fs.Path walRootDir, WALFactory walFactory, MasterRegionWALRoller walRoller, String serverName)
void	requestRollAll()
private void	shutdownWAL()
void	update(UpdateMasterRegion action)
void	waitUntilWalRollFinished()

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

REPLAY_EDITS_DIR

private static final String REPLAY_EDITS_DIR

See Also:

Constant Field Values

DEAD_WAL_DIR_SUFFIX

private static final String DEAD_WAL_DIR_SUFFIX

See Also:

Constant Field Values

REGION_ID

private static final int REGION_ID

See Also:

Constant Field Values

walFactory

private final WALFactory walFactory

region

final HRegion region

flusherAndCompactor

final MasterRegionFlusherAndCompactor flusherAndCompactor

walRoller

private MasterRegionWALRoller walRoller

Constructor Detail

MasterRegion

private MasterRegion(HRegion region,
                     WALFactory walFactory,
                     MasterRegionFlusherAndCompactor flusherAndCompactor,
                     MasterRegionWALRoller walRoller)

Method Detail

closeRegion

private void closeRegion(boolean abort)

shutdownWAL

private void shutdownWAL()

update

public void update(UpdateMasterRegion action)
            throws IOException

Throws:

IOException

get

public Result get(Get get)
           throws IOException

Throws:

IOException

getScanner

public RegionScanner getScanner(Scan scan)
                         throws IOException

Throws:

IOException

flush

public HRegion.FlushResult flush(boolean force)
                          throws IOException

Throws:

IOException

requestRollAll

public void requestRollAll()

waitUntilWalRollFinished

public void waitUntilWalRollFinished()
                              throws InterruptedException

Throws:

InterruptedException

close

public void close(boolean abort)

createWAL

private static WAL createWAL(WALFactory walFactory,
                             MasterRegionWALRoller walRoller,
                             String serverName,
                             org.apache.hadoop.fs.FileSystem walFs,
                             org.apache.hadoop.fs.Path walRootDir,
                             RegionInfo regionInfo)
                      throws IOException

Throws:

IOException

bootstrap

private static HRegion bootstrap(org.apache.hadoop.conf.Configuration conf,
                                 TableDescriptor td,
                                 org.apache.hadoop.fs.FileSystem fs,
                                 org.apache.hadoop.fs.Path rootDir,
                                 org.apache.hadoop.fs.FileSystem walFs,
                                 org.apache.hadoop.fs.Path walRootDir,
                                 WALFactory walFactory,
                                 MasterRegionWALRoller walRoller,
                                 String serverName)
                          throws IOException

Throws:

IOException

open

private static HRegion open(org.apache.hadoop.conf.Configuration conf,
                            TableDescriptor td,
                            org.apache.hadoop.fs.FileSystem fs,
                            org.apache.hadoop.fs.Path rootDir,
                            org.apache.hadoop.fs.FileSystem walFs,
                            org.apache.hadoop.fs.Path walRootDir,
                            WALFactory walFactory,
                            MasterRegionWALRoller walRoller,
                            String serverName)
                     throws IOException

Throws:

IOException

create

public static MasterRegion create(MasterRegionParams params)
                           throws IOException

Throws:

IOException