Package org.apache.hadoop.hbase.replication.regionserver

Class Replication

java.lang.Object

org.apache.hadoop.hbase.replication.regionserver.Replication

All Implemented Interfaces:

ConfigurationObserver, PropagatingConfigurationObserver, ReplicationService, ReplicationSourceService

@Private
public class Replication
extends Object
implements ReplicationSourceService, PropagatingConfigurationObserver

Gateway to Replication. Used by HRegionServer.

Implement PropagatingConfigurationObserver mainly for registering ReplicationPeers, so we can recreating the replication peer storage.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
private final class	Replication.ReplicationStatisticsChore	Statistics task.

Field Summary

Fields

Modifier and Type	Field	Description
private org.apache.hadoop.conf.Configuration	conf
private MetricsReplicationGlobalSourceSource	globalMetricsSource
private boolean	isReplicationForBulkLoadDataEnabled
private static final org.slf4j.Logger	LOG
private PeerProcedureHandler	peerProcedureHandler
private ReplicationQueueStorage	queueStorage
private ReplicationLoad	replicationLoad
private ReplicationSourceManager	replicationManager
private ReplicationPeers	replicationPeers
private Server	server
private int	statsPeriodInSecond
private SyncReplicationPeerInfoProvider	syncReplicationPeerInfoProvider

Constructor Summary

Constructors

Constructor	Description
Replication()	Empty constructor

Method Summary

Modifier and Type	Method	Description
(package private) void	addHFileRefsToQueue(TableName tableName, byte[] family, List<Pair<org.apache.hadoop.fs.Path,org.apache.hadoop.fs.Path>> pairs)
void	deregisterChildren(ConfigurationManager manager)	Needs to be called to deregister the children from the manager.
PeerProcedureHandler	getPeerProcedureHandler()	Returns a Handler to handle peer procedures.
ReplicationSourceManager	getReplicationManager()	Get the replication sources manager
ReplicationPeers	getReplicationPeers()	Return the replication peers.
SyncReplicationPeerInfoProvider	getSyncReplicationPeerInfoProvider()	Returns an info provider for sync replication peer.
void	initialize(Server server, org.apache.hadoop.fs.FileSystem fs, org.apache.hadoop.fs.Path logDir, org.apache.hadoop.fs.Path oldLogDir, WALFactory walFactory)	Initializes the replication service object.
void	onConfigurationChange(org.apache.hadoop.conf.Configuration conf)	This method would be called by the ConfigurationManager object when the Configuration object is reloaded from disk.
ReplicationLoad	refreshAndGetReplicationLoad()	Refresh and Get ReplicationLoad
void	registerChildren(ConfigurationManager manager)	Needs to be called to register the children to the manager.
void	startReplicationService()	If replication is enabled and this cluster is a master, it starts
void	stopReplicationService()	Stops replication service.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Details

LOG

private static final org.slf4j.Logger LOG

isReplicationForBulkLoadDataEnabled

private boolean isReplicationForBulkLoadDataEnabled

replicationManager

private ReplicationSourceManager replicationManager

queueStorage

private ReplicationQueueStorage queueStorage

replicationPeers

private ReplicationPeers replicationPeers

conf

private volatile org.apache.hadoop.conf.Configuration conf

syncReplicationPeerInfoProvider

private SyncReplicationPeerInfoProvider syncReplicationPeerInfoProvider

server

private Server server

statsPeriodInSecond

private int statsPeriodInSecond

replicationLoad

private ReplicationLoad replicationLoad

globalMetricsSource

private MetricsReplicationGlobalSourceSource globalMetricsSource

peerProcedureHandler

private PeerProcedureHandler peerProcedureHandler

Constructor Details

Replication

public Replication()

Empty constructor

Method Details

initialize

public void initialize(Server server,
 org.apache.hadoop.fs.FileSystem fs,
 org.apache.hadoop.fs.Path logDir,
 org.apache.hadoop.fs.Path oldLogDir,
 WALFactory walFactory)
                throws IOException

Description copied from interface: ReplicationService

Initializes the replication service object.

Specified by:

initialize in interface ReplicationService

Throws:

IOException

getPeerProcedureHandler

public PeerProcedureHandler getPeerProcedureHandler()

Description copied from interface: ReplicationSourceService

Returns a Handler to handle peer procedures.

Specified by:

getPeerProcedureHandler in interface ReplicationSourceService

stopReplicationService

public void stopReplicationService()

Stops replication service.

Specified by:

stopReplicationService in interface ReplicationService

startReplicationService

public void startReplicationService()
                             throws IOException

If replication is enabled and this cluster is a master, it starts

Specified by:

startReplicationService in interface ReplicationService

Throws:

IOException

getReplicationManager

public ReplicationSourceManager getReplicationManager()

Get the replication sources manager

Specified by:

getReplicationManager in interface ReplicationSourceService

Returns:

the manager if replication is enabled, else returns false

addHFileRefsToQueue

void addHFileRefsToQueue(TableName tableName,
 byte[] family,
 List<Pair<org.apache.hadoop.fs.Path,org.apache.hadoop.fs.Path>> pairs)
                  throws IOException

Throws:

IOException

refreshAndGetReplicationLoad

public ReplicationLoad refreshAndGetReplicationLoad()

Description copied from interface: ReplicationService

Refresh and Get ReplicationLoad

Specified by:

refreshAndGetReplicationLoad in interface ReplicationService

getSyncReplicationPeerInfoProvider

public SyncReplicationPeerInfoProvider getSyncReplicationPeerInfoProvider()

Description copied from interface: ReplicationSourceService

Returns an info provider for sync replication peer.

Specified by:

getSyncReplicationPeerInfoProvider in interface ReplicationSourceService

getReplicationPeers

public ReplicationPeers getReplicationPeers()

Description copied from interface: ReplicationSourceService

Return the replication peers.

Specified by:

getReplicationPeers in interface ReplicationSourceService

onConfigurationChange

public void onConfigurationChange(org.apache.hadoop.conf.Configuration conf)

Description copied from interface: ConfigurationObserver

This method would be called by the ConfigurationManager object when the Configuration object is reloaded from disk.

Specified by:

onConfigurationChange in interface ConfigurationObserver

registerChildren

public void registerChildren(ConfigurationManager manager)

Description copied from interface: PropagatingConfigurationObserver

Needs to be called to register the children to the manager.

Specified by:

registerChildren in interface PropagatingConfigurationObserver

Parameters:

manager - : to register to

deregisterChildren

public void deregisterChildren(ConfigurationManager manager)

Description copied from interface: PropagatingConfigurationObserver

Needs to be called to deregister the children from the manager.

Specified by:

deregisterChildren in interface PropagatingConfigurationObserver

Parameters:

manager - : to deregister from