org.apache.hadoop.hbase.replication

Class TestReplicationEndpoint.SleepingReplicationEndpointForTest

java.lang.Object

org.apache.hbase.thirdparty.com.google.common.util.concurrent.AbstractService

org.apache.hadoop.hbase.replication.BaseReplicationEndpoint

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

org.apache.hadoop.hbase.replication.TestReplicationEndpoint.SleepingReplicationEndpointForTest

All Implemented Interfaces:

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

Enclosing class:

TestReplicationEndpoint

public static class TestReplicationEndpoint.SleepingReplicationEndpointForTest
extends TestReplicationEndpoint.ReplicationEndpointForTest

Not used by unit tests, helpful for manual testing with replication.

Snippet for `hbase shell`:

 create 't', 'f'
 add_peer '1', ENDPOINT_CLASSNAME => 'org.apache.hadoop.hbase.replication.' + \
    'TestReplicationEndpoint$SleepingReplicationEndpointForTest'
 alter 't', {NAME=>'f', REPLICATION_SCOPE=>1}
 

Nested Class Summary

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

org.apache.hadoop.hbase.replication.ReplicationEndpoint.Context, org.apache.hadoop.hbase.replication.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 long	duration

Fields inherited from class org.apache.hadoop.hbase.replication.TestReplicationEndpoint.ReplicationEndpointForTest

contructedCount, lastEntries, replicateCount, startedCount, stoppedCount, uuid

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

ctx, REPLICATION_WALENTRYFILTER_CONFIG_KEY

Constructor Summary

Constructors

Constructor and Description
SleepingReplicationEndpointForTest()

Method Summary

Modifier and Type	Method and Description
void	init(org.apache.hadoop.hbase.replication.ReplicationEndpoint.Context context)
boolean	replicate(org.apache.hadoop.hbase.replication.ReplicationEndpoint.ReplicateContext context)

Methods inherited from class org.apache.hadoop.hbase.replication.TestReplicationEndpoint.ReplicationEndpointForTest

canReplicateToSameCluster, doStart, doStop, getPeerUUID, start, stop

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

getNamespaceTableCfWALEntryFilter, getScopeWALEntryFilter, 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

duration

private long duration

Constructor Detail

SleepingReplicationEndpointForTest

public SleepingReplicationEndpointForTest()

Method Detail

init

public void init(org.apache.hadoop.hbase.replication.ReplicationEndpoint.Context context)
          throws IOException

Specified by:

init in interface org.apache.hadoop.hbase.replication.ReplicationEndpoint

Overrides:

init in class org.apache.hadoop.hbase.replication.BaseReplicationEndpoint

Throws:

IOException

replicate

public boolean replicate(org.apache.hadoop.hbase.replication.ReplicationEndpoint.ReplicateContext context)

Specified by:

replicate in interface org.apache.hadoop.hbase.replication.ReplicationEndpoint

Overrides:

replicate in class TestReplicationEndpoint.ReplicationEndpointForTest