|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectorg.apache.hadoop.hbase.replication.regionserver.Replication
public class Replication
Gateway to Replication. Used by HRegionServer
.
Constructor Summary | |
---|---|
Replication(Server server,
org.apache.hadoop.fs.FileSystem fs,
org.apache.hadoop.fs.Path logDir,
org.apache.hadoop.fs.Path oldLogDir)
Instantiate the replication management (if rep is enabled). |
Method Summary | |
---|---|
static void |
decorateMasterConfiguration(org.apache.hadoop.conf.Configuration conf)
This method modifies the master's configuration in order to inject replication-related features |
ReplicationSourceManager |
getReplicationManager()
Get the replication sources manager |
static boolean |
isReplication(org.apache.hadoop.conf.Configuration c)
|
void |
join()
Join with the replication threads |
void |
logCloseRequested()
The WAL is about to close. |
void |
logRolled(org.apache.hadoop.fs.Path p)
The WAL was rolled. |
void |
logRollRequested()
A request was made that the WAL be rolled. |
void |
replicateLogEntries(HLog.Entry[] entries)
Carry on the list of log entries down to the sink |
void |
startReplicationServices()
If replication is enabled and this cluster is a master, it starts |
void |
visitLogEntryBeforeWrite(HRegionInfo info,
HLogKey logKey,
WALEdit logEdit)
Called before each write. |
Methods inherited from class java.lang.Object |
---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Constructor Detail |
---|
public Replication(Server server, org.apache.hadoop.fs.FileSystem fs, org.apache.hadoop.fs.Path logDir, org.apache.hadoop.fs.Path oldLogDir) throws IOException, org.apache.zookeeper.KeeperException
server
- Hosting serverfs
- handle to the filesystemlogDir
- oldLogDir
- directory where logs are archived
IOException
org.apache.zookeeper.KeeperException
Method Detail |
---|
public static boolean isReplication(org.apache.hadoop.conf.Configuration c)
c
- Configuration to look at
public void join()
public void replicateLogEntries(HLog.Entry[] entries) throws IOException
entries
- list of entries to replicate
IOException
public void startReplicationServices() throws IOException
IOException
public ReplicationSourceManager getReplicationManager()
public void visitLogEntryBeforeWrite(HRegionInfo info, HLogKey logKey, WALEdit logEdit)
WALObserver
visitLogEntryBeforeWrite
in interface WALObserver
public void logRolled(org.apache.hadoop.fs.Path p)
WALObserver
logRolled
in interface WALObserver
p
- the path to the new hlogpublic static void decorateMasterConfiguration(org.apache.hadoop.conf.Configuration conf)
conf
- public void logRollRequested()
WALObserver
logRollRequested
in interface WALObserver
public void logCloseRequested()
WALObserver
logCloseRequested
in interface WALObserver
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |