Package | Description |
---|---|
org.apache.hadoop.hbase.regionserver | |
org.apache.hadoop.hbase.replication.regionserver |
Modifier and Type | Method and Description |
---|---|
ReplicationSourceManager |
ReplicationSourceService.getReplicationManager()
Returns the replication manager
|
Modifier and Type | Field and Description |
---|---|
private ReplicationSourceManager |
ReplicationSourceWALActionListener.manager |
protected ReplicationSourceManager |
ReplicationSource.manager |
private ReplicationSourceManager |
Replication.replicationManager |
private ReplicationSourceManager |
Replication.ReplicationStatisticsTask.replicationManager |
private ReplicationSourceManager |
PeerProcedureHandlerImpl.replicationSourceManager |
Modifier and Type | Method and Description |
---|---|
ReplicationSourceManager |
Replication.getReplicationManager()
Get the replication sources manager
|
ReplicationSourceManager |
ReplicationSourceInterface.getSourceManager()
Returns the replication source manager
|
ReplicationSourceManager |
ReplicationSource.getSourceManager() |
Modifier and Type | Method and Description |
---|---|
private void |
ReplicationSyncUp.claimReplicationQueues(ZKWatcher zkw,
ReplicationSourceManager mgr) |
void |
RecoveredReplicationSource.init(org.apache.hadoop.conf.Configuration conf,
org.apache.hadoop.fs.FileSystem fs,
ReplicationSourceManager manager,
ReplicationQueueStorage queueStorage,
ReplicationPeer replicationPeer,
Server server,
String peerClusterZnode,
UUID clusterId,
WALFileLengthProvider walFileLengthProvider,
MetricsSource metrics) |
void |
ReplicationSourceInterface.init(org.apache.hadoop.conf.Configuration conf,
org.apache.hadoop.fs.FileSystem fs,
ReplicationSourceManager manager,
ReplicationQueueStorage queueStorage,
ReplicationPeer replicationPeer,
Server server,
String queueId,
UUID clusterId,
WALFileLengthProvider walFileLengthProvider,
MetricsSource metrics)
Initializer for the source
|
void |
ReplicationSource.init(org.apache.hadoop.conf.Configuration conf,
org.apache.hadoop.fs.FileSystem fs,
ReplicationSourceManager manager,
ReplicationQueueStorage queueStorage,
ReplicationPeer replicationPeer,
Server server,
String queueId,
UUID clusterId,
WALFileLengthProvider walFileLengthProvider,
MetricsSource metrics)
Instantiation method used by region servers
|
protected void |
ReplicationSource.uncaughtException(Thread t,
Throwable e,
ReplicationSourceManager manager,
String peerId) |
Constructor and Description |
---|
PeerProcedureHandlerImpl(ReplicationSourceManager replicationSourceManager) |
ReplicationSourceWALActionListener(org.apache.hadoop.conf.Configuration conf,
ReplicationSourceManager manager) |
ReplicationStatisticsTask(ReplicationSink replicationSink,
ReplicationSourceManager replicationManager) |
Copyright © 2007–2020 The Apache Software Foundation. All rights reserved.