| 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() | 
| ReplicationSourceManager | ReplicationSource. getSourceManager() | 
| Modifier and Type | Method and Description | 
|---|---|
| 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–2021 The Apache Software Foundation. All rights reserved.