org.apache.hadoop.hbase.replication

Class TestReplicationEndpoint.ReplicationEndpointForTest

java.lang.Object

AbstractService

org.apache.hadoop.hbase.replication.BaseReplicationEndpoint

org.apache.hadoop.hbase.replication.TestReplicationEndpoint.ReplicationEndpointForTest

All Implemented Interfaces:

ReplicationEndpoint

Direct Known Subclasses:

TestReplicationEndpoint.ReplicationEndpointReturningFalse, TestReplicationEndpoint.ReplicationEndpointWithWALEntryFilter

Enclosing class:

TestReplicationEndpoint

public static class TestReplicationEndpoint.ReplicationEndpointForTest
extends BaseReplicationEndpoint

Nested Class Summary

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

ReplicationEndpoint.Context, ReplicationEndpoint.ReplicateContext

Field Summary

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

ctx

Constructor Summary

Constructors

Constructor and Description
ReplicationEndpointForTest()

Method Summary

Modifier and Type	Method and Description
protected void	doStart()
protected void	doStop()
UUID	getPeerUUID() Returns a UUID of the provided peer id.
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.BaseReplicationEndpoint

canReplicateToSameCluster, getScopeWALEntryFilter, getTableCfWALEntryFilter, getWALEntryfilter, init

Methods inherited from class java.lang.Object

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

Constructor Detail

ReplicationEndpointForTest

public ReplicationEndpointForTest()

Method Detail

getPeerUUID

public UUID getPeerUUID()

Description copied from interface: ReplicationEndpoint

Returns a UUID of the provided peer id. Every HBase cluster instance has a persisted associated UUID. If the replication is not performed to an actual HBase cluster (but some other system), the UUID returned has to uniquely identify the connected target system.

Returns:

a UUID or null if the peer cluster does not exist or is not connected.

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.

doStart

protected void doStart()

doStop

protected void doStop()