| Package | Description | 
|---|---|
| org.apache.hadoop.hbase.replication | Multi Cluster Replication | 
| org.apache.hadoop.hbase.replication.regionserver | 
| Modifier and Type | Field and Description | 
|---|---|
| private MetricsSource | ReplicationEndpoint.Context. metrics | 
| Modifier and Type | Method and Description | 
|---|---|
| MetricsSource | ReplicationEndpoint.Context. getMetrics() | 
| Constructor and Description | 
|---|
| Context(org.apache.hadoop.conf.Configuration localConf,
       org.apache.hadoop.conf.Configuration conf,
       org.apache.hadoop.fs.FileSystem fs,
       String peerId,
       UUID clusterId,
       ReplicationPeer replicationPeer,
       MetricsSource metrics,
       TableDescriptors tableDescriptors,
       Abortable abortable) | 
| Modifier and Type | Field and Description | 
|---|---|
| private MetricsSource | WALEntryStream. metrics | 
| private MetricsSource | HBaseInterClusterReplicationEndpoint. metrics | 
| private MetricsSource | ReplicationSource. metrics | 
| Modifier and Type | Method and Description | 
|---|---|
| MetricsSource | ReplicationSourceInterface. getSourceMetrics() | 
| MetricsSource | ReplicationSource. getSourceMetrics() | 
| 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 | 
| Constructor and Description | 
|---|
| WALEntryStream(PriorityBlockingQueue<org.apache.hadoop.fs.Path> logQueue,
              org.apache.hadoop.conf.Configuration conf,
              long startPosition,
              WALFileLengthProvider walFileLengthProvider,
              ServerName serverName,
              MetricsSource metrics)Create an entry stream over the given queue at the given start position | 
Copyright © 2007–2021 The Apache Software Foundation. All rights reserved.