@InterfaceAudience.Private public class MasterWalManager extends Object
| Constructor and Description |
|---|
MasterWalManager(org.apache.hadoop.conf.Configuration conf,
org.apache.hadoop.fs.FileSystem fs,
org.apache.hadoop.fs.Path rootDir,
MasterServices services) |
MasterWalManager(MasterServices services) |
| Modifier and Type | Method and Description |
|---|---|
Set<ServerName> |
getFailedServersFromLogFolders()
Deprecated.
With proc-v2, we can record the crash server with procedure store, so do not need
to scan the wal directory to find out the splitting wal directory any more. Leave
it here only because
RecoverMetaProcedure(which is also deprecated) uses
it. |
org.apache.hadoop.fs.FileSystem |
getFileSystem() |
Set<ServerName> |
getLiveServersFromWALDir() |
void |
splitLog(ServerName serverName) |
void |
splitLog(Set<ServerName> serverNames) |
void |
splitLog(Set<ServerName> serverNames,
org.apache.hadoop.fs.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(Set<ServerName> serverNames)
Specialized method to handle the splitting for meta WAL
|
void |
stop() |
public MasterWalManager(MasterServices services) throws IOException
IOExceptionpublic MasterWalManager(org.apache.hadoop.conf.Configuration conf,
org.apache.hadoop.fs.FileSystem fs,
org.apache.hadoop.fs.Path rootDir,
MasterServices services)
throws IOException
IOExceptionpublic void stop()
public org.apache.hadoop.fs.FileSystem getFileSystem()
public Set<ServerName> getLiveServersFromWALDir() throws IOException
IOException@Deprecated public Set<ServerName> getFailedServersFromLogFolders()
RecoverMetaProcedure(which is also deprecated) uses
it.public void splitLog(ServerName serverName) throws IOException
IOExceptionpublic void splitMetaLog(ServerName serverName) throws IOException
serverName - logs belonging to this server will be splitIOExceptionpublic void splitMetaLog(Set<ServerName> serverNames) throws IOException
serverNames - logs belonging to these servers will be splitIOExceptionpublic void splitLog(Set<ServerName> serverNames) throws IOException
IOExceptionpublic void splitLog(Set<ServerName> serverNames, org.apache.hadoop.fs.PathFilter filter) throws IOException
serverNames - logs belonging to these servers will be split; this will rename the log
directory out from under a soft-failed serverIOExceptionCopyright © 2007–2018 The Apache Software Foundation. All rights reserved.