org.apache.hadoop.hbase.replication.regionserver

Class TestReplicationSource.FaultyReplicationEndpoint

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.TestReplicationSource.DoNothingReplicationEndpoint

org.apache.hadoop.hbase.replication.regionserver.TestReplicationSource.FaultyReplicationEndpoint

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:

TestReplicationSource

public static class TestReplicationSource.FaultyReplicationEndpoint
extends TestReplicationSource.DoNothingReplicationEndpoint

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
(package private) static int	count

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
FaultyReplicationEndpoint()

Method Summary

Modifier and Type	Method and Description
UUID	getPeerUUID()

Methods inherited from class org.apache.hadoop.hbase.replication.regionserver.TestReplicationSource.DoNothingReplicationEndpoint

canReplicateToSameCluster, doStart, doStop, getWALEntryfilter, init

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

createConnection, createReplicationSinkManager, createReplicator, filterNotExistColumnFamilyEdits, filterNotExistTableEdits, isNoSuchColumnFamilyException, isPeerEnabled, isTableNotFoundException, replicate, replicateEntries

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

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

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

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

count

static int count

Constructor Detail

FaultyReplicationEndpoint

public FaultyReplicationEndpoint()

Method Detail

getPeerUUID

public UUID getPeerUUID()

Specified by:

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

Overrides:

getPeerUUID in class TestReplicationSource.DoNothingReplicationEndpoint