org.apache.hadoop.hbase.replication.regionserver

Class TestReplicationSinkManager.SetServersHBaseReplicationEndpoint

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.TestReplicationSinkManager.SetServersHBaseReplicationEndpoint

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:

TestReplicationSinkManager

private static class TestReplicationSinkManager.SetServersHBaseReplicationEndpoint
extends org.apache.hadoop.hbase.replication.HBaseReplicationEndpoint

Manage the 'getRegionServers' for the tests below. Override the base class handling of Regionservers. We used to use a mock for this but updated guava/errorprone disallows mocking of classes that implement Service.

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) List<org.apache.hadoop.hbase.ServerName>	regionServers

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

ctx, REPLICATION_WALENTRYFILTER_CONFIG_KEY

Constructor Summary

Constructors

Modifier	Constructor and Description
private	SetServersHBaseReplicationEndpoint()

Method Summary

Modifier and Type	Method and Description
List<org.apache.hadoop.hbase.ServerName>	getRegionServers()
boolean	replicate(org.apache.hadoop.hbase.replication.ReplicationEndpoint.ReplicateContext replicateContext)
void	setRegionServers(List<org.apache.hadoop.hbase.ServerName> regionServers)

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

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

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

canReplicateToSameCluster, getNamespaceTableCfWALEntryFilter, getScopeWALEntryFilter, getWALEntryfilter, init, 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

regionServers

List<org.apache.hadoop.hbase.ServerName> regionServers

Constructor Detail

SetServersHBaseReplicationEndpoint

private SetServersHBaseReplicationEndpoint()

Method Detail

replicate

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

setRegionServers

public void setRegionServers(List<org.apache.hadoop.hbase.ServerName> regionServers)

Overrides:

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

getRegionServers

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

Overrides:

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