org.apache.hadoop.hbase.replication.regionserver

Class RegionReplicaReplicationEndpoint

java.lang.Object

org.apache.hbase.thirdparty.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:

Abortable, ReplicationEndpoint, ReplicationPeerConfigListener, org.apache.hbase.thirdparty.com.google.common.util.concurrent.Service

@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>

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 org.apache.hbase.thirdparty.com.google.common.util.concurrent.Service

org.apache.hbase.thirdparty.com.google.common.util.concurrent.Service.Listener, org.apache.hbase.thirdparty.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 EntryBuffers	entryBuffers
private static org.slf4j.Logger	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, REPLICATION_WALENTRYFILTER_CONFIG_KEY

Constructor Summary

Constructors

Constructor and Description
RegionReplicaReplicationEndpoint()

Method Summary

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.
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, start, stop

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

getNamespaceTableCfWALEntryFilter, getWALEntryfilter, isStarting, peerConfigUpdated

Methods inherited from class org.apache.hbase.thirdparty.com.google.common.util.concurrent.AbstractService

addListener, awaitRunning, awaitRunning, awaitRunning, awaitTerminated, awaitTerminated, awaitTerminated, doCancelStart, failureCause, isRunning, notifyFailed, notifyStarted, notifyStopped, startAsync, state, stopAsync, toString

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.hadoop.hbase.replication.ReplicationEndpoint

awaitRunning, awaitRunning, awaitTerminated, awaitTerminated, failureCause, isRunning

Field Detail

LOG

private static final org.slf4j.Logger 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 EntryBuffers entryBuffers

numWriterThreads

private int numWriterThreads

operationTimeout

private int operationTimeout

pool

private ExecutorService pool

Constructor Detail

RegionReplicaReplicationEndpoint

public RegionReplicaReplicationEndpoint()

Method Detail

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 - error occur when initialize the endpoint.

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