org.apache.hadoop.hbase.replication.regionserver

Class TestSerialReplicationEndpoint.TestEndpoint

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.TestSerialReplicationEndpoint.TestEndpoint

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

Enclosing class:

TestSerialReplicationEndpoint

public static class TestSerialReplicationEndpoint.TestEndpoint
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
private static BlockingQueue<org.apache.hadoop.hbase.wal.WAL.Entry>	entryQueue

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

REPLICATION_DROP_ON_DELETED_COLUMN_FAMILY_KEY, REPLICATION_DROP_ON_DELETED_TABLE_KEY

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

ctx, REPLICATION_WALENTRYFILTER_CONFIG_KEY

Constructor Summary

Constructors

Constructor and Description
TestEndpoint()

Method Summary

Modifier and Type	Method and Description
boolean	canReplicateToSameCluster()
protected Callable<Integer>	createReplicator(List<org.apache.hadoop.hbase.wal.WAL.Entry> entries, int ordinal, int timeout)
static List<org.apache.hadoop.hbase.wal.WAL.Entry>	getEntries()
List<org.apache.hadoop.hbase.ServerName>	getRegionServers()
static void	reset()

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

createConnection, createReplicationSinkManager, doStop, filterNotExistColumnFamilyEdits, filterNotExistTableEdits, init, isNoSuchColumnFamilyException, isPeerEnabled, isTableNotFoundException, replicate, replicateEntries

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

abort, disconnect, doStart, fetchSlavesAddresses, getLastRegionServerUpdate, getPeerUUID, getZkw, isAborted, reconnect, setRegionServers, 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.Abortable

abort

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

awaitRunning, awaitRunning, awaitTerminated, awaitTerminated, failureCause, isRunning

Field Detail

entryQueue

private static final BlockingQueue<org.apache.hadoop.hbase.wal.WAL.Entry> entryQueue

Constructor Detail

TestEndpoint

public TestEndpoint()

Method Detail

reset

public static void reset()

getEntries

public static List<org.apache.hadoop.hbase.wal.WAL.Entry> getEntries()

canReplicateToSameCluster

public boolean canReplicateToSameCluster()

Specified by:

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

Overrides:

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

createReplicator

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

Overrides:

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

getRegionServers

public List<org.apache.hadoop.hbase.ServerName> getRegionServers()

Overrides:

getRegionServers in class org.apache.hadoop.hbase.replication.HBaseReplicationEndpoint