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 and Description
private static class	MockMasterServices.MockRegionStateStore

Field Summary

Fields

Modifier and Type	Field and Description
private org.apache.hadoop.hbase.master.assignment.AssignmentManager	assignmentManager
private org.apache.hadoop.hbase.master.LoadBalancer	balancer
private org.apache.hadoop.hbase.client.ClusterConnection	connection
static String	DEFAULT_COLUMN_FAMILY_NAME
private org.apache.hadoop.hbase.master.MasterFileSystem	fileSystemManager
private org.apache.hadoop.hbase.procedure2.ProcedureEvent<?>	initialized
static 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 org.apache.hadoop.hbase.master.ServerManager	serverManager
private org.apache.hadoop.hbase.master.SplitWALManager	splitWALManager
private org.apache.hadoop.hbase.master.TableStateManager	tableStateManager
private org.apache.hadoop.hbase.master.MasterWalManager	walManager

Constructor Summary

Constructors

Constructor and Description
MockMasterServices(org.apache.hadoop.conf.Configuration conf, NavigableMap<org.apache.hadoop.hbase.ServerName,SortedSet<byte[]>> regionsToRegionServers)

Method Summary

Modifier and Type	Method and 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.ClusterConnection	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.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, getAccessChecker, getCatalogJanitor, getChoreService, getClientIdAuditPrefix, getClusterConnection, getClusterSchema, getConfiguration, getExecutorService, getFavoredNodesManager, getFileSystem, getLastMajorCompactionTimestamp, getLastMajorCompactionTimestampForRegion, getLockManager, getLocks, getMasterCoprocessorHost, getMasterMetrics, getMasterProcedureManagerHost, getMasterQuotaManager, getMetaLocationSyncer, getProcedures, getRegionNormalizerManager, getRegionServerVersion, getReplicationPeerConfig, getReplicationPeerManager, getSnapshotManager, getZKPermissionWatcher, getZooKeeper, isAborted, isActiveMaster, isClusterUp, isInMaintenanceMode, isSplitOrMergeEnabled, isStopped, isStopping, listReplicationPeers, listTableDescriptorsByNamespace, listTableNamesByNamespace, mergeRegions, modifyColumn, modifyTable, normalizeRegions, registerService, removeReplicationPeer, runReplicationBarrierCleaner, skipRegionManagementAction, splitRegion, truncateTable, updateReplicationPeerConfig

Methods inherited from class java.lang.Object

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

Field Detail

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

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.ClusterConnection connection

balancer

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

serverManager

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

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 Detail

MockMasterServices

public MockMasterServices(org.apache.hadoop.conf.Configuration conf,
                          NavigableMap<org.apache.hadoop.hbase.ServerName,SortedSet<byte[]>> regionsToRegionServers)
                   throws IOException

Throws:

IOException

Method Detail

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.ClusterConnection 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()