Modifier and Type | Class and Description |
---|---|
static class |
MiniHBaseCluster.MiniHBaseClusterRegionServer
Subclass so can get at protected methods (none at moment).
|
class |
MockRegionServerServices
Basic mock region server services.
|
static class |
TestLocalHBaseCluster.MyHMaster
A private master class similar to that used by HMasterCommandLine when
running in local mode.
|
static class |
TestLocalHBaseCluster.MyHRegionServer
A private regionserver class with a dummy method for testing casts
|
Modifier and Type | Method and Description |
---|---|
Server |
CoordinatedStateManager.getServer() |
Modifier and Type | Method and Description |
---|---|
void |
HBaseTestingUtility.expireSession(ZooKeeperWatcher nodeZK,
Server server)
Deprecated.
|
void |
CoordinatedStateManager.initialize(Server server)
Initialize coordinated state management service.
|
Modifier and Type | Field and Description |
---|---|
protected Server |
ZkCoordinatedStateManager.server |
Modifier and Type | Method and Description |
---|---|
Server |
BaseCoordinatedStateManager.getServer() |
Server |
ZkCoordinatedStateManager.getServer() |
Modifier and Type | Method and Description |
---|---|
void |
BaseCoordinatedStateManager.initialize(Server server) |
void |
ZkCoordinatedStateManager.initialize(Server server) |
Modifier and Type | Field and Description |
---|---|
protected Server |
EventHandler.server |
Constructor and Description |
---|
EventHandler(Server server,
EventType eventType)
Default base class constructor.
|
TestEventHandler(Server server,
EventType eventType,
AtomicBoolean lock,
AtomicInteger counter) |
Constructor and Description |
---|
RpcServer(Server server,
String name,
List<RpcServer.BlockingServiceAndInterface> services,
InetSocketAddress bindAddress,
Configuration conf,
RpcScheduler scheduler)
Constructs a server listening on the named port and address.
|
Modifier and Type | Interface and Description |
---|---|
interface |
MasterServices
Services Master supplies
|
Modifier and Type | Class and Description |
---|---|
class |
HMaster
HMaster is the "master server" for HBase.
|
static class |
HMasterCommandLine.LocalHMaster |
static class |
TestActiveMasterManager.DummyMaster
Dummy Master Implementation.
|
static class |
TestAssignmentManagerOnCluster.MyMaster |
static class |
TestAssignmentManagerOnCluster.MyRegionServer |
static class |
TestMasterMetrics.MyMaster |
static class |
TestMetaShutdownHandler.MyRegionServer |
Modifier and Type | Field and Description |
---|---|
protected Server |
AssignmentManager.server |
protected Server |
BulkAssigner.server |
Constructor and Description |
---|
AssignmentManager(Server server,
ServerManager serverManager,
LoadBalancer balancer,
ExecutorService service,
MetricsMaster metricsMaster,
TableLockManager tableLockManager)
Constructs a new assignment manager.
|
BulkAssigner(Server server) |
BulkReOpen(Server server,
Map<ServerName,List<HRegionInfo>> serverToRegions,
AssignmentManager am) |
GeneralBulkAssigner(Server server,
Map<ServerName,List<HRegionInfo>> bulkPlan,
AssignmentManager am,
boolean waitTillAllAssigned) |
MasterFileSystem(Server master,
MasterServices services) |
ServerManager(Server master,
MasterServices services)
Constructor.
|
SplitLogManager(Server server,
Configuration conf,
Stoppable stopper,
MasterServices master,
ServerName serverName)
Its OK to construct this object even when region-servers are not online.
|
Modifier and Type | Field and Description |
---|---|
protected Server |
LogReplayHandler.master |
Modifier and Type | Interface and Description |
---|---|
interface |
OnlineRegions
Interface to Map of online regions.
|
interface |
RegionServerServices
Services provided by
HRegionServer |
Modifier and Type | Class and Description |
---|---|
class |
HRegionServer
HRegionServer makes a set of HRegions available to clients.
|
class |
OOMERegionServer
A region server that will OOME.
|
static class |
TestRegionServerReportForDuty.MyRegionServer |
static class |
TestRSKilledWhenInitializing.MockedRegionServer |
static class |
TestSplitTransactionOnCluster.MockMasterWithoutCatalogJanitor |
Modifier and Type | Method and Description |
---|---|
Server |
RegionMergeTransaction.getServer()
Get the Server running the transaction or rollback
|
Server |
RegionMergeTransactionImpl.getServer() |
Server |
SplitTransaction.getServer()
Get the Server running the transaction or rollback
|
Server |
SplitTransactionImpl.getServer() |
Modifier and Type | Method and Description |
---|---|
static HeapMemoryManager |
HeapMemoryManager.create(Configuration conf,
FlushRequester memStoreFlusher,
Server server) |
Region |
RegionMergeTransaction.execute(Server server,
RegionServerServices services)
Deprecated.
use #execute(Server, RegionServerServices, User)
|
HRegion |
RegionMergeTransactionImpl.execute(Server server,
RegionServerServices services)
Run the transaction.
|
PairOfSameType<Region> |
SplitTransaction.execute(Server server,
RegionServerServices services)
Deprecated.
use #execute(Server, RegionServerServices, User)
|
PairOfSameType<Region> |
SplitTransactionImpl.execute(Server server,
RegionServerServices services) |
Region |
RegionMergeTransaction.execute(Server server,
RegionServerServices services,
User user)
Run the transaction.
|
HRegion |
RegionMergeTransactionImpl.execute(Server server,
RegionServerServices services,
User user) |
PairOfSameType<Region> |
SplitTransaction.execute(Server server,
RegionServerServices services,
User user)
Run the transaction.
|
PairOfSameType<Region> |
SplitTransactionImpl.execute(Server server,
RegionServerServices services,
User user)
Run the transaction.
|
void |
ReplicationService.initialize(Server rs,
FileSystem fs,
Path logdir,
Path oldLogDir)
Initializes the replication service object.
|
void |
TestSplitTransactionOnCluster.MockedCoordinatedStateManager.initialize(Server server,
HRegion region) |
boolean |
RegionMergeTransaction.rollback(Server server,
RegionServerServices services)
Deprecated.
use #rollback(Server, RegionServerServices, User)
|
boolean |
RegionMergeTransactionImpl.rollback(Server server,
RegionServerServices services) |
boolean |
SplitTransaction.rollback(Server server,
RegionServerServices services)
Deprecated.
use #rollback(Server, RegionServerServices, User)
|
boolean |
SplitTransactionImpl.rollback(Server server,
RegionServerServices services) |
boolean |
TestSplitTransactionOnCluster.MockedSplitTransaction.rollback(Server server,
RegionServerServices services) |
boolean |
RegionMergeTransaction.rollback(Server server,
RegionServerServices services,
User user)
Roll back a failed transaction
|
boolean |
RegionMergeTransactionImpl.rollback(Server server,
RegionServerServices services,
User user) |
boolean |
SplitTransaction.rollback(Server server,
RegionServerServices services,
User user)
Roll back a failed transaction
|
boolean |
SplitTransactionImpl.rollback(Server server,
RegionServerServices services,
User user) |
void |
RegionMergeTransactionImpl.stepsAfterPONR(Server server,
RegionServerServices services,
HRegion mergedRegion)
Deprecated.
|
void |
RegionMergeTransactionImpl.stepsAfterPONR(Server server,
RegionServerServices services,
HRegion mergedRegion,
User user) |
PairOfSameType<Region> |
SplitTransactionImpl.stepsAfterPONR(Server server,
RegionServerServices services,
PairOfSameType<Region> regions)
Deprecated.
|
PairOfSameType<Region> |
SplitTransactionImpl.stepsAfterPONR(Server server,
RegionServerServices services,
PairOfSameType<Region> regions,
User user) |
HRegion |
RegionMergeTransactionImpl.stepsBeforePONR(Server server,
RegionServerServices services,
boolean testing) |
PairOfSameType<Region> |
SplitTransactionImpl.stepsBeforePONR(Server server,
RegionServerServices services,
boolean testing) |
Constructor and Description |
---|
LogRoller(Server server,
RegionServerServices services) |
SplitLogWorker(Server hserver,
Configuration conf,
RegionServerServices server,
LastSequenceId sequenceIdChecker,
WALFactory factory) |
SplitLogWorker(Server hserver,
Configuration conf,
RegionServerServices server,
SplitLogWorker.TaskExecutor splitTaskExecutor) |
Modifier and Type | Method and Description |
---|---|
protected ReplicationSourceInterface |
ReplicationSourceManager.getReplicationSource(Configuration conf,
FileSystem fs,
ReplicationSourceManager manager,
ReplicationQueues replicationQueues,
ReplicationPeers replicationPeers,
Server server,
String peerId,
UUID clusterId,
ReplicationPeerConfig peerConfig,
ReplicationPeer replicationPeer)
Factory method to create a replication source
|
void |
Replication.initialize(Server server,
FileSystem fs,
Path logDir,
Path oldLogDir) |
Constructor and Description |
---|
Replication(Server server,
FileSystem fs,
Path logDir,
Path oldLogDir)
Instantiate the replication management (if rep is enabled).
|
ReplicationSourceManager(ReplicationQueues replicationQueues,
ReplicationPeers replicationPeers,
ReplicationTracker replicationTracker,
Configuration conf,
Server server,
FileSystem fs,
Path logDir,
Path oldLogDir,
UUID clusterId)
Creates a replication manager and sets the watch on all the other registered region servers
|
Modifier and Type | Class and Description |
---|---|
class |
MockServer
Basic mock Server for handler tests.
|
Constructor and Description |
---|
RegionServerTracker(ZooKeeperWatcher watcher,
Server server,
ServerManager serverManager) |