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.IOExceptionpublic MasterWalManager(Configuration conf,
FileSystem fs,
Path rootDir,
MasterServices services)
throws java.io.IOException
java.io.IOExceptionpublic void stop()
public FileSystem getFileSystem()
public java.util.Set<ServerName> getFailedServersFromLogFolders()
public void splitLog(ServerName serverName)
throws java.io.IOException
java.io.IOExceptionpublic void splitMetaLog(ServerName serverName)
throws java.io.IOException
serverName - logs belonging to this server will be splitjava.io.IOExceptionpublic void splitMetaLog(java.util.Set<ServerName> serverNames)
throws java.io.IOException
serverNames - logs belonging to these servers will be splitjava.io.IOExceptionpublic void splitLog(java.util.Set<ServerName> serverNames)
throws java.io.IOException
java.io.IOExceptionpublic 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