RegionReplicaReplicationEndpoint (Apache HBase 1.2.12 API)

java.lang.Object
- com.google.common.util.concurrent.AbstractService
- - org.apache.hadoop.hbase.replication.BaseReplicationEndpoint
  - - org.apache.hadoop.hbase.replication.HBaseReplicationEndpoint
    - - org.apache.hadoop.hbase.replication.regionserver.RegionReplicaReplicationEndpoint

All Implemented Interfaces:

com.google.common.util.concurrent.Service, Abortable, ReplicationEndpoint
```
@InterfaceAudience.Private
public class RegionReplicaReplicationEndpoint
extends HBaseReplicationEndpoint
```
A ReplicationEndpoint endpoint which receives the WAL edits from the WAL, and sends the edits to replicas of regions.

Nested Class Summary

Nested Classes
Modifier and Type	Class and Description
`(package private) static class`	`RegionReplicaReplicationEndpoint.RegionReplicaOutputSink`
`(package private) static class`	`RegionReplicaReplicationEndpoint.RegionReplicaReplayCallable` Calls replay on the passed edits for the given set of entries belonging to the region.
`(package private) static class`	`RegionReplicaReplicationEndpoint.RegionReplicaSinkWriter`
`(package private) static class`	`RegionReplicaReplicationEndpoint.RetryingRpcCallable<V>`
`private static class`	`RegionReplicaReplicationEndpoint.SkipReplayedEditsFilter` Skips the entries which has original seqId.

Nested classes/interfaces inherited from class org.apache.hadoop.hbase.replication.HBaseReplicationEndpoint
HBaseReplicationEndpoint.PeerRegionServerListener

Nested classes/interfaces inherited from interface org.apache.hadoop.hbase.replication.ReplicationEndpoint
ReplicationEndpoint.Context, ReplicationEndpoint.ReplicateContext

Nested classes/interfaces inherited from interface com.google.common.util.concurrent.Service
com.google.common.util.concurrent.Service.State

Field Summary

Fields
Modifier and Type	Field and Description
`private static String`	`CLIENT_RETRIES_NUMBER`
`private org.apache.hadoop.conf.Configuration`	`conf`
`private ClusterConnection`	`connection`
`private WALSplitter.PipelineController`	`controller`
`private WALSplitter.EntryBuffers`	`entryBuffers`
`private static org.apache.commons.logging.Log`	`LOG`
`private int`	`numWriterThreads`
`private int`	`operationTimeout`
`private RegionReplicaReplicationEndpoint.RegionReplicaOutputSink`	`outputSink`
`private ExecutorService`	`pool`
`private TableDescriptors`	`tableDescriptors`

Fields inherited from class org.apache.hadoop.hbase.replication.BaseReplicationEndpoint
ctx

Constructor Summary

Constructors
Constructor and Description

RegionReplicaReplicationEndpoint()

Constructors
Constructor and Description
`RegionReplicaReplicationEndpoint()`

Method Summary

Methods
Modifier and Type	Method and Description
`boolean`	`canReplicateToSameCluster()` Whether or not, the replication endpoint can replicate to it's source cluster with the same UUID
`protected void`	`doStart()`
`protected void`	`doStop()`
`private ExecutorService`	`getDefaultThreadPool(org.apache.hadoop.conf.Configuration conf)` Returns a Thread pool for the RPC's to region replicas.
`protected WALEntryFilter`	`getScopeWALEntryFilter()` Returns a WALEntryFilter for checking the scope.
`protected WALEntryFilter`	`getSkipReplayedEditsFilter()`
`WALEntryFilter`	`getWALEntryfilter()` Returns a default set of filters
`void`	`init(ReplicationEndpoint.Context context)` Initialize the replication endpoint with the given context.
`boolean`	`replicate(ReplicationEndpoint.ReplicateContext replicateContext)` Replicate the given set of entries (in the context) to the other cluster.

Methods inherited from class org.apache.hadoop.hbase.replication.HBaseReplicationEndpoint
abort, disconnect, fetchSlavesAddresses, getLastRegionServerUpdate, getPeerUUID, getRegionServers, getZkw, isAborted, reconnect, setRegionServers

Methods inherited from class org.apache.hadoop.hbase.replication.BaseReplicationEndpoint
getTableCfWALEntryFilter

Methods inherited from class com.google.common.util.concurrent.AbstractService
isRunning, notifyFailed, notifyStarted, notifyStopped, start, startAndWait, state, stop, stopAndWait, toString

Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Methods inherited from interface com.google.common.util.concurrent.Service
isRunning, start, startAndWait, state, stop, stopAndWait

- Field Detail
  - LOG
```
private static final org.apache.commons.logging.Log LOG
```
  - CLIENT_RETRIES_NUMBER
```
private static String CLIENT_RETRIES_NUMBER
```
  - conf
```
private org.apache.hadoop.conf.Configuration conf
```
  - connection
```
private ClusterConnection connection
```
  - tableDescriptors
```
private TableDescriptors tableDescriptors
```
  - controller
```
private WALSplitter.PipelineController controller
```
  - outputSink
```
private RegionReplicaReplicationEndpoint.RegionReplicaOutputSink outputSink
```
  - entryBuffers
```
private WALSplitter.EntryBuffers entryBuffers
```
  - numWriterThreads
```
private int numWriterThreads
```
  - operationTimeout
```
private int operationTimeout
```
  - pool
```
private ExecutorService pool
```
- Constructor Detail
  - RegionReplicaReplicationEndpoint
```
public RegionReplicaReplicationEndpoint()
```
- Method Detail
  - getWALEntryfilter
```
public WALEntryFilter getWALEntryfilter()
```
    Description copied from class: BaseReplicationEndpoint
    
    Returns a default set of filters
    
    Specified by:
    
    getWALEntryfilter in interface ReplicationEndpoint
    
    Overrides:
    
    getWALEntryfilter in class BaseReplicationEndpoint
    
    Returns:
    a WALEntryFilter or null.
  - getSkipReplayedEditsFilter
```
protected WALEntryFilter getSkipReplayedEditsFilter()
```
  - init
```
public void init(ReplicationEndpoint.Context context)
          throws IOException
```
    Description copied from interface: ReplicationEndpoint
    
    Initialize the replication endpoint with the given context.
    
    Specified by:
    
    init in interface ReplicationEndpoint
    
    Overrides:
    
    init in class BaseReplicationEndpoint
    
    Parameters:
    context - replication context
    
    Throws:
    
    IOException
  - doStart
```
protected void doStart()
```
    Overrides:
    
    doStart in class HBaseReplicationEndpoint
  - doStop
```
protected void doStop()
```
    Overrides:
    
    doStop in class HBaseReplicationEndpoint
  - getDefaultThreadPool
```
private ExecutorService getDefaultThreadPool(org.apache.hadoop.conf.Configuration conf)
```
    Returns a Thread pool for the RPC's to region replicas. Similar to Connection's thread pool.
  - replicate
```
public boolean replicate(ReplicationEndpoint.ReplicateContext replicateContext)
```
    Description copied from interface: ReplicationEndpoint
    
    Replicate the given set of entries (in the context) to the other cluster. Can block until all the given entries are replicated. Upon this method is returned, all entries that were passed in the context are assumed to be persisted in the target cluster.
    
    Parameters:
    replicateContext - a context where WAL entries and other parameters can be obtained.
  - canReplicateToSameCluster
```
public boolean canReplicateToSameCluster()
```
    Description copied from interface: ReplicationEndpoint
    
    Whether or not, the replication endpoint can replicate to it's source cluster with the same UUID
    
    Specified by:
    
    canReplicateToSameCluster in interface ReplicationEndpoint
    
    Overrides:
    
    canReplicateToSameCluster in class BaseReplicationEndpoint
  - getScopeWALEntryFilter
```
protected WALEntryFilter getScopeWALEntryFilter()
```
    Description copied from class: BaseReplicationEndpoint
    
    Returns a WALEntryFilter for checking the scope. Subclasses can return null if they don't want this filter
    
    Overrides:
    
    getScopeWALEntryFilter in class BaseReplicationEndpoint

Class RegionReplicaReplicationEndpoint

Nested Class Summary

Nested classes/interfaces inherited from class org.apache.hadoop.hbase.replication.HBaseReplicationEndpoint

Nested classes/interfaces inherited from interface org.apache.hadoop.hbase.replication.ReplicationEndpoint

Nested classes/interfaces inherited from interface com.google.common.util.concurrent.Service

Field Summary

Fields inherited from class org.apache.hadoop.hbase.replication.BaseReplicationEndpoint

Constructor Summary

Method Summary

Methods inherited from class org.apache.hadoop.hbase.replication.HBaseReplicationEndpoint

Methods inherited from class org.apache.hadoop.hbase.replication.BaseReplicationEndpoint

Methods inherited from class com.google.common.util.concurrent.AbstractService

Methods inherited from class java.lang.Object

Methods inherited from interface com.google.common.util.concurrent.Service

Field Detail

LOG

CLIENT_RETRIES_NUMBER

conf

connection

tableDescriptors

controller

outputSink

entryBuffers

numWriterThreads

operationTimeout

pool

Constructor Detail

RegionReplicaReplicationEndpoint

Method Detail

getWALEntryfilter

getSkipReplayedEditsFilter

init

doStart

doStop

getDefaultThreadPool

replicate

canReplicateToSameCluster

getScopeWALEntryFilter