public class MasterWalManager
extends java.lang.Object
Constructor and Description |
---|
MasterWalManager(Configuration conf,
FileSystem fs,
Path rootDir,
MasterServices services) |
MasterWalManager(MasterServices services) |
Modifier and Type | Method and Description |
---|---|
java.util.Set<ServerName> |
getFailedServersFromLogFolders()
Inspect the log directory to find dead servers which need recovery work
|
FileSystem |
getFileSystem() |
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() |
public MasterWalManager(MasterServices services) throws java.io.IOException
java.io.IOException
public MasterWalManager(Configuration conf, FileSystem fs, Path rootDir, MasterServices services) throws java.io.IOException
java.io.IOException
public void stop()
public FileSystem getFileSystem()
public java.util.Set<ServerName> getFailedServersFromLogFolders()
public void splitLog(ServerName serverName) throws java.io.IOException
java.io.IOException
public void splitMetaLog(ServerName serverName) throws java.io.IOException
serverName
- logs belonging to this server will be splitjava.io.IOException
public void splitMetaLog(java.util.Set<ServerName> serverNames) throws java.io.IOException
serverNames
- logs belonging to these servers will be splitjava.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 serverjava.io.IOException