@InterfaceAudience.Private public class MasterFileSystem extends java.lang.Object
Modifier and Type | Field and Description |
---|---|
static java.lang.String |
HBASE_DIR_PERMS
Parameter name for HBase instance root directory permission
|
static java.lang.String |
HBASE_WAL_DIR_PERMS
Parameter name for HBase WAL directory permission
|
Constructor and Description |
---|
MasterFileSystem(Server master,
MasterServices services) |
Modifier and Type | Method and Description |
---|---|
HTableDescriptor |
addColumn(TableName tableName,
HColumnDescriptor hcd)
Add column to a table
|
boolean |
checkFileSystem()
Checks to see if the file system is still accessible.
|
HTableDescriptor |
deleteColumn(TableName tableName,
byte[] familyName)
Delete column of a table
|
void |
deleteFamilyFromFS(HRegionInfo region,
byte[] familyName,
boolean hasMob) |
void |
deleteRegion(HRegionInfo region) |
void |
deleteTable(TableName tableName) |
ClusterId |
getClusterId() |
Configuration |
getConfiguration() |
FileSystem |
getFileSystem() |
ZooKeeperProtos.SplitLogTask.RecoveryMode |
getLogRecoveryMode() |
Path |
getOldLogDir()
Get the directory where old logs go
|
Path |
getRootDir() |
Path |
getTempDir() |
protected FileSystem |
getWALFileSystem() |
Path |
getWALRootDir() |
HTableDescriptor |
modifyColumn(TableName tableName,
HColumnDescriptor hcd)
Modify Column of a table
|
Path |
moveTableToTemp(TableName tableName)
Move the specified table to the hbase temp directory
|
void |
prepareLogReplay(ServerName serverName,
java.util.Set<HRegionInfo> regions)
Mark regions in recovering state when distributedLogReplay are set true
|
static void |
setInfoFamilyCachingForMeta(HTableDescriptor metaDescriptor,
boolean b)
Enable in memory caching for hbase:meta
|
void |
setLogRecoveryMode()
The function is used in SSH to set recovery mode based on configuration after all outstanding
log split tasks drained.
|
void |
splitLog(ServerName serverName) |
void |
splitLog(java.util.Set<ServerName> serverNames) |
void |
splitLog(java.util.Set<ServerName> serverNames,
PathFilter filter)
This method is the base split method that splits WAL files matching a filter.
|
void |
splitMetaLog(ServerName serverName)
Specialized method to handle the splitting for meta WAL
|
void |
splitMetaLog(java.util.Set<ServerName> serverNames)
Specialized method to handle the splitting for meta WAL
|
void |
stop() |
void |
updateRegionInfo(HRegionInfo region) |
public static final java.lang.String HBASE_DIR_PERMS
public static final java.lang.String HBASE_WAL_DIR_PERMS
public MasterFileSystem(Server master, MasterServices services) throws java.io.IOException
java.io.IOException
public FileSystem getFileSystem()
public Path getOldLogDir()
public boolean checkFileSystem()
protected FileSystem getWALFileSystem()
public Configuration getConfiguration()
public Path getRootDir()
public Path getWALRootDir()
public Path getTempDir()
public ClusterId getClusterId()
public void splitLog(ServerName serverName) throws java.io.IOException
java.io.IOException
public void splitMetaLog(ServerName serverName) throws java.io.IOException
serverName
- java.io.IOException
public void splitMetaLog(java.util.Set<ServerName> serverNames) throws java.io.IOException
serverNames
- java.io.IOException
public void prepareLogReplay(ServerName serverName, java.util.Set<HRegionInfo> regions) throws java.io.IOException
serverName
- Failed region server whose wals to be replayedregions
- Set of regions to be recoveredjava.io.IOException
public void splitLog(java.util.Set<ServerName> serverNames) throws java.io.IOException
java.io.IOException
public void splitLog(java.util.Set<ServerName> serverNames, PathFilter filter) throws java.io.IOException
serverNames
- logs belonging to these servers will be split; this will rename the log
directory out from under a soft-failed serverfilter
- java.io.IOException
public static void setInfoFamilyCachingForMeta(HTableDescriptor metaDescriptor, boolean b)
public void deleteRegion(HRegionInfo region) throws java.io.IOException
java.io.IOException
public void deleteTable(TableName tableName) throws java.io.IOException
java.io.IOException
public Path moveTableToTemp(TableName tableName) throws java.io.IOException
tableName
- Table name to movejava.io.IOException
- in case of file-system failurepublic void updateRegionInfo(HRegionInfo region)
public void deleteFamilyFromFS(HRegionInfo region, byte[] familyName, boolean hasMob) throws java.io.IOException
java.io.IOException
public void stop()
public HTableDescriptor deleteColumn(TableName tableName, byte[] familyName) throws java.io.IOException
tableName
- familyName
- java.io.IOException
public HTableDescriptor modifyColumn(TableName tableName, HColumnDescriptor hcd) throws java.io.IOException
tableName
- hcd
- HColumnDesciptorjava.io.IOException
public HTableDescriptor addColumn(TableName tableName, HColumnDescriptor hcd) throws java.io.IOException
tableName
- hcd
- java.io.IOException
public void setLogRecoveryMode() throws java.io.IOException
java.io.IOException
public ZooKeeperProtos.SplitLogTask.RecoveryMode getLogRecoveryMode()