org.apache.hadoop.hbase.replication.regionserver

Class TestReplicator.ReplicationEndpointForTest

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.HBaseInterClusterReplicationEndpoint

org.apache.hadoop.hbase.replication.regionserver.TestReplicator.ReplicationEndpointForTest

All Implemented Interfaces:

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

Direct Known Subclasses:

TestReplicator.FailureInjectingReplicationEndpointForTest

Enclosing class:

TestReplicator

public static class TestReplicator.ReplicationEndpointForTest
extends org.apache.hadoop.hbase.replication.regionserver.HBaseInterClusterReplicationEndpoint

Nested Class Summary

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

org.apache.hadoop.hbase.replication.HBaseReplicationEndpoint.PeerRegionServerListener

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
protected static AtomicInteger	batchCount
protected static int	entriesCount
private static Object	latch
private static AtomicBoolean	useLatch

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

ctx, REPLICATION_WALENTRYFILTER_CONFIG_KEY

Constructor Summary

Constructors

Constructor and Description
ReplicationEndpointForTest()

Method Summary

Modifier and Type	Method and Description
static void	await()
protected Callable<Integer>	createReplicator(List<org.apache.hadoop.hbase.wal.WAL.Entry> entries, int ordinal)
static int	getBatchCount()
static int	getEntriesCount()
static void	pause()
boolean	replicate(org.apache.hadoop.hbase.replication.ReplicationEndpoint.ReplicateContext replicateContext)
static void	resume()
static void	setBatchCount(int i)
static void	setEntriesCount(int i)

Methods inherited from class org.apache.hadoop.hbase.replication.regionserver.HBaseInterClusterReplicationEndpoint

doStop, init, isPeerEnabled, replicateEntries, sleepForRetries

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

abort, disconnect, doStart, fetchSlavesAddresses, getLastRegionServerUpdate, getPeerUUID, getRegionServers, getZkw, isAborted, reconnect, setRegionServers, start, stop

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

canReplicateToSameCluster, getNamespaceTableCfWALEntryFilter, getScopeWALEntryFilter, getWALEntryfilter, isStarting, peerConfigUpdated

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

addListener, awaitRunning, awaitRunning, awaitTerminated, awaitTerminated, 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

batchCount

protected static AtomicInteger batchCount

entriesCount

protected static int entriesCount

latch

private static final Object latch

useLatch

private static AtomicBoolean useLatch

Constructor Detail

ReplicationEndpointForTest

public ReplicationEndpointForTest()

Method Detail

resume

public static void resume()

pause

public static void pause()

await

public static void await()
                  throws InterruptedException

Throws:

InterruptedException

getBatchCount

public static int getBatchCount()

setBatchCount

public static void setBatchCount(int i)

getEntriesCount

public static int getEntriesCount()

setEntriesCount

public static void setEntriesCount(int i)

replicate

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

Specified by:

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

Overrides:

replicate in class org.apache.hadoop.hbase.replication.regionserver.HBaseInterClusterReplicationEndpoint

createReplicator

protected Callable<Integer> createReplicator(List<org.apache.hadoop.hbase.wal.WAL.Entry> entries,
                                             int ordinal)

Overrides:

createReplicator in class org.apache.hadoop.hbase.replication.regionserver.HBaseInterClusterReplicationEndpoint