Package org.apache.hadoop.hbase.master.assignment

Class MockMasterServices

java.lang.Object

org.apache.hadoop.hbase.master.MockNoopMasterServices

org.apache.hadoop.hbase.master.assignment.MockMasterServices

All Implemented Interfaces:

org.apache.hadoop.hbase.Abortable, org.apache.hadoop.hbase.master.MasterServices, org.apache.hadoop.hbase.Server, org.apache.hadoop.hbase.Stoppable

public class MockMasterServices
extends MockNoopMasterServices

A mocked master services. Tries to fake it. May not always work.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
private static class	MockMasterServices.MockRegionStateStore

Field Summary

Fields

Modifier and Type	Field	Description
private final org.apache.hadoop.hbase.master.assignment.AssignmentManager	assignmentManager
private final org.apache.hadoop.hbase.master.LoadBalancer	balancer
private final org.apache.hadoop.hbase.client.Connection	connection
static final String	DEFAULT_COLUMN_FAMILY_NAME
private final org.apache.hadoop.hbase.master.MasterFileSystem	fileSystemManager
private final org.apache.hadoop.hbase.procedure2.ProcedureEvent<?>	initialized
private final org.apache.hadoop.hbase.master.region.MasterRegion	masterRegion
static final org.apache.hadoop.hbase.ServerName	MOCK_MASTER_SERVERNAME
private org.apache.hadoop.hbase.master.procedure.MasterProcedureEnv	procedureEnv
private org.apache.hadoop.hbase.procedure2.ProcedureExecutor<org.apache.hadoop.hbase.master.procedure.MasterProcedureEnv>	procedureExecutor
private org.apache.hadoop.hbase.procedure2.store.ProcedureStore	procedureStore
private final org.apache.hadoop.hbase.master.replication.ReplicationPeerManager	rpm
private final org.apache.hadoop.hbase.master.ServerManager	serverManager
private final org.apache.hadoop.hbase.master.SplitWALManager	splitWALManager
private final org.apache.hadoop.hbase.master.TableStateManager	tableStateManager
private final org.apache.hadoop.hbase.master.MasterWalManager	walManager

Constructor Summary

Constructors

Constructor	Description
MockMasterServices(org.apache.hadoop.conf.Configuration conf)

Method Summary

Modifier and Type	Method	Description
private static org.apache.hadoop.hbase.shaded.protobuf.generated.ClientProtos.MultiResponse	buildMultiResponse(org.apache.hadoop.hbase.shaded.protobuf.generated.ClientProtos.MultiRequest req)
org.apache.hadoop.hbase.master.assignment.AssignmentManager	getAssignmentManager()
org.apache.hadoop.hbase.client.Connection	getConnection()
org.apache.hadoop.hbase.CoordinatedStateManager	getCoordinatedStateManager()
org.apache.hadoop.hbase.procedure2.ProcedureEvent<?>	getInitializedEvent()
org.apache.hadoop.hbase.master.LoadBalancer	getLoadBalancer()
org.apache.hadoop.hbase.master.MasterFileSystem	getMasterFileSystem()
org.apache.hadoop.hbase.procedure2.ProcedureExecutor<org.apache.hadoop.hbase.master.procedure.MasterProcedureEnv>	getMasterProcedureExecutor()
org.apache.hadoop.hbase.master.MasterWalManager	getMasterWalManager()
org.apache.hadoop.hbase.master.replication.ReplicationPeerManager	getReplicationPeerManager()
org.apache.hadoop.hbase.master.ServerManager	getServerManager()
org.apache.hadoop.hbase.ServerName	getServerName()
org.apache.hadoop.hbase.master.SplitWALManager	getSplitWALManager()
org.apache.hadoop.hbase.TableDescriptors	getTableDescriptors()
org.apache.hadoop.hbase.master.TableStateManager	getTableStateManager()
boolean	isInitialized()
void	restartRegionServer(org.apache.hadoop.hbase.ServerName serverName)	Call this restart method only after running MockMasterServices#start() The RSs can be differentiated by the port number, see ServerName in MockMasterServices#start() method above.
void	start(int numServes, org.apache.hadoop.hbase.master.procedure.RSProcedureDispatcher remoteDispatcher)
private void	startProcedureExecutor(org.apache.hadoop.hbase.master.procedure.RSProcedureDispatcher remoteDispatcher)
void	stop(String why)
private void	stopProcedureExecutor()

Methods inherited from class org.apache.hadoop.hbase.master.MockNoopMasterServices

abort, abortProcedure, addColumn, addReplicationPeer, checkIfShouldMoveSystemRegionAsync, checkTableModifiable, createConnection, createSystemTable, createTable, deleteColumn, deleteTable, disableReplicationPeer, disableTable, enableReplicationPeer, enableTable, executeRegionPlansWithThrottling, flushMasterStore, flushTable, getAccessChecker, getAsyncClusterConnection, getCatalogJanitor, getChoreService, getClientIdAuditPrefix, getClusterSchema, getConfiguration, getExecutorService, getFavoredNodesManager, getFileSystem, getHbckChore, getLastMajorCompactionTimestamp, getLastMajorCompactionTimestampForRegion, getLockManager, getLocks, getMasterCoprocessorHost, getMasterMetrics, getMasterProcedureManagerHost, getMasterQuotaManager, getMetaLocationSyncer, getProcedures, getRegionNormalizerManager, getRegionServerVersion, getReplicationLogCleanerBarrier, getReplicationPeerConfig, getRSGroupInfoManager, getSnapshotManager, getSyncReplicationPeerLock, getSyncReplicationReplayWALManager, getZKPermissionWatcher, getZooKeeper, isAborted, isActiveMaster, isBalancerOn, isClusterUp, isInMaintenanceMode, isReplicationPeerModificationEnabled, isSplitOrMergeEnabled, isStopped, isStopping, listReplicationPeers, listTableDescriptorsByNamespace, listTableNamesByNamespace, mergeRegions, modifyColumn, modifyColumnStoreFileTracker, modifyTable, modifyTable, modifyTableStoreFileTracker, normalizeRegions, registerService, removeReplicationPeer, replicationPeerModificationSwitch, runReplicationBarrierCleaner, skipRegionManagementAction, splitRegion, transitReplicationPeerSyncReplicationState, truncateRegion, truncateTable, updateReplicationPeerConfig

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface org.apache.hadoop.hbase.Abortable

abort

Methods inherited from interface org.apache.hadoop.hbase.Server

getAsyncConnection

Field Details

fileSystemManager

private final org.apache.hadoop.hbase.master.MasterFileSystem fileSystemManager

walManager

private final org.apache.hadoop.hbase.master.MasterWalManager walManager

splitWALManager

private final org.apache.hadoop.hbase.master.SplitWALManager splitWALManager

assignmentManager

private final org.apache.hadoop.hbase.master.assignment.AssignmentManager assignmentManager

tableStateManager

private final org.apache.hadoop.hbase.master.TableStateManager tableStateManager

masterRegion

private final org.apache.hadoop.hbase.master.region.MasterRegion masterRegion

procedureEnv

private org.apache.hadoop.hbase.master.procedure.MasterProcedureEnv procedureEnv

procedureExecutor

private org.apache.hadoop.hbase.procedure2.ProcedureExecutor<org.apache.hadoop.hbase.master.procedure.MasterProcedureEnv> procedureExecutor

procedureStore

private org.apache.hadoop.hbase.procedure2.store.ProcedureStore procedureStore

connection

private final org.apache.hadoop.hbase.client.Connection connection

balancer

private final org.apache.hadoop.hbase.master.LoadBalancer balancer

serverManager

private final org.apache.hadoop.hbase.master.ServerManager serverManager

rpm

private final org.apache.hadoop.hbase.master.replication.ReplicationPeerManager rpm

initialized

private final org.apache.hadoop.hbase.procedure2.ProcedureEvent<?> initialized

DEFAULT_COLUMN_FAMILY_NAME

public static final String DEFAULT_COLUMN_FAMILY_NAME

See Also:

• Constant Field Values

MOCK_MASTER_SERVERNAME

public static final org.apache.hadoop.hbase.ServerName MOCK_MASTER_SERVERNAME

Constructor Details

MockMasterServices

public MockMasterServices(org.apache.hadoop.conf.Configuration conf)
                   throws IOException,
org.apache.hadoop.hbase.replication.ReplicationException

Throws:

IOException

org.apache.hadoop.hbase.replication.ReplicationException

Method Details

start

public void start(int numServes,
 org.apache.hadoop.hbase.master.procedure.RSProcedureDispatcher remoteDispatcher)
           throws IOException,
org.apache.zookeeper.KeeperException

Throws:

IOException

org.apache.zookeeper.KeeperException

restartRegionServer

public void restartRegionServer(org.apache.hadoop.hbase.ServerName serverName)
                         throws IOException

Call this restart method only after running MockMasterServices#start() The RSs can be differentiated by the port number, see ServerName in MockMasterServices#start() method above. Restart of region server will have new startcode in server name

Parameters:

serverName - Server name to be restarted

Throws:

IOException

stop

public void stop(String why)

Specified by:

stop in interface org.apache.hadoop.hbase.Stoppable

Overrides:

stop in class MockNoopMasterServices

startProcedureExecutor

private void startProcedureExecutor(org.apache.hadoop.hbase.master.procedure.RSProcedureDispatcher remoteDispatcher)
                             throws IOException

Throws:

IOException

stopProcedureExecutor

private void stopProcedureExecutor()

isInitialized

public boolean isInitialized()

Specified by:

isInitialized in interface org.apache.hadoop.hbase.master.MasterServices

Overrides:

isInitialized in class MockNoopMasterServices

getInitializedEvent

public org.apache.hadoop.hbase.procedure2.ProcedureEvent<?> getInitializedEvent()

Specified by:

getInitializedEvent in interface org.apache.hadoop.hbase.master.MasterServices

Overrides:

getInitializedEvent in class MockNoopMasterServices

getMasterFileSystem

public org.apache.hadoop.hbase.master.MasterFileSystem getMasterFileSystem()

Specified by:

getMasterFileSystem in interface org.apache.hadoop.hbase.master.MasterServices

Overrides:

getMasterFileSystem in class MockNoopMasterServices

getMasterWalManager

public org.apache.hadoop.hbase.master.MasterWalManager getMasterWalManager()

Specified by:

getMasterWalManager in interface org.apache.hadoop.hbase.master.MasterServices

Overrides:

getMasterWalManager in class MockNoopMasterServices

getMasterProcedureExecutor

public org.apache.hadoop.hbase.procedure2.ProcedureExecutor<org.apache.hadoop.hbase.master.procedure.MasterProcedureEnv> getMasterProcedureExecutor()

Specified by:

getMasterProcedureExecutor in interface org.apache.hadoop.hbase.master.MasterServices

Overrides:

getMasterProcedureExecutor in class MockNoopMasterServices

getLoadBalancer

public org.apache.hadoop.hbase.master.LoadBalancer getLoadBalancer()

Specified by:

getLoadBalancer in interface org.apache.hadoop.hbase.master.MasterServices

Overrides:

getLoadBalancer in class MockNoopMasterServices

getServerManager

public org.apache.hadoop.hbase.master.ServerManager getServerManager()

Specified by:

getServerManager in interface org.apache.hadoop.hbase.master.MasterServices

Overrides:

getServerManager in class MockNoopMasterServices

getAssignmentManager

public org.apache.hadoop.hbase.master.assignment.AssignmentManager getAssignmentManager()

Specified by:

getAssignmentManager in interface org.apache.hadoop.hbase.master.MasterServices

Overrides:

getAssignmentManager in class MockNoopMasterServices

getTableStateManager

public org.apache.hadoop.hbase.master.TableStateManager getTableStateManager()

Specified by:

getTableStateManager in interface org.apache.hadoop.hbase.master.MasterServices

Overrides:

getTableStateManager in class MockNoopMasterServices

getConnection

public org.apache.hadoop.hbase.client.Connection getConnection()

Specified by:

getConnection in interface org.apache.hadoop.hbase.Server

Overrides:

getConnection in class MockNoopMasterServices

getServerName

public org.apache.hadoop.hbase.ServerName getServerName()

Specified by:

getServerName in interface org.apache.hadoop.hbase.Server

Overrides:

getServerName in class MockNoopMasterServices

getCoordinatedStateManager

public org.apache.hadoop.hbase.CoordinatedStateManager getCoordinatedStateManager()

Specified by:

getCoordinatedStateManager in interface org.apache.hadoop.hbase.Server

Overrides:

getCoordinatedStateManager in class MockNoopMasterServices

getTableDescriptors

public org.apache.hadoop.hbase.TableDescriptors getTableDescriptors()

Specified by:

getTableDescriptors in interface org.apache.hadoop.hbase.master.MasterServices

Overrides:

getTableDescriptors in class MockNoopMasterServices

buildMultiResponse

private static org.apache.hadoop.hbase.shaded.protobuf.generated.ClientProtos.MultiResponse buildMultiResponse(org.apache.hadoop.hbase.shaded.protobuf.generated.ClientProtos.MultiRequest req)

getSplitWALManager

public org.apache.hadoop.hbase.master.SplitWALManager getSplitWALManager()

getReplicationPeerManager

public org.apache.hadoop.hbase.master.replication.ReplicationPeerManager getReplicationPeerManager()

Specified by:

getReplicationPeerManager in interface org.apache.hadoop.hbase.master.MasterServices

Overrides:

getReplicationPeerManager in class MockNoopMasterServices