Modifier and Type | Interface and Description |
---|---|
interface |
Server
Defines the set of shared functions implemented by HBase servers (Masters
and RegionServers).
|
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.
|
Modifier and Type | Class and Description |
---|---|
class |
BackupHFileCleaner
Implementation of a file cleaner that checks if an hfile is still referenced by backup before
deleting it from hfile archive directory.
|
Modifier and Type | Class and Description |
---|---|
class |
LogRollBackupSubprocedurePool
Handle running each of the individual tasks for completing a backup procedure
on a regionserver.
|
Modifier and Type | Interface and Description |
---|---|
interface |
Admin
The administrative API for HBase.
|
interface |
ClusterConnection
Internal methods on Connection that should not be used by user code.
|
interface |
Connection
A cluster connection encapsulating lower level individual connections to actual servers and
a connection to zookeeper.
|
interface |
HConnection
Deprecated.
in favor of
Connection and ConnectionFactory |
Modifier and Type | Class and Description |
---|---|
class |
CoprocessorHConnection
Connection to an HTable from within a Coprocessor.
|
class |
HBaseAdmin
HBaseAdmin is no longer a client API.
|
Modifier and Type | Field and Description |
---|---|
protected Abortable |
CoprocessorHost.abortable |
Constructor and Description |
---|
CoprocessorHost(Abortable abortable) |
MasterTracker(ZooKeeperWatcher zkw,
java.lang.String masterNode,
Abortable abortable) |
MasterTracker(ZooKeeperWatcher zkw,
java.lang.String masterNode,
Abortable abortable) |
Constructor and Description |
---|
BalancedQueueRpcExecutor(java.lang.String name,
int handlerCount,
int numQueues,
Configuration conf,
Abortable abortable,
java.lang.Class<? extends java.util.concurrent.BlockingQueue> queueClass,
java.lang.Object... initargs) |
BalancedQueueRpcExecutor(java.lang.String name,
int handlerCount,
int numQueues,
int maxQueueLength,
Configuration conf,
Abortable abortable) |
FastPathBalancedQueueRpcExecutor(java.lang.String name,
int handlerCount,
int numCallQueues,
Configuration conf,
Abortable abortable,
java.lang.Class<? extends java.util.concurrent.BlockingQueue> queueClass,
java.lang.Object... args) |
FastPathBalancedQueueRpcExecutor(java.lang.String name,
int handlerCount,
int numQueues,
int maxQueueLength,
Configuration conf,
Abortable abortable) |
RpcExecutor(java.lang.String name,
int handlerCount,
Configuration conf,
Abortable abortable) |
RWQueueRpcExecutor(java.lang.String name,
int handlerCount,
int numQueues,
float readShare,
float scanShare,
int maxQueueLength,
Configuration conf,
Abortable abortable) |
RWQueueRpcExecutor(java.lang.String name,
int handlerCount,
int numQueues,
float readShare,
float scanShare,
int maxQueueLength,
Configuration conf,
Abortable abortable,
java.lang.Class<? extends java.util.concurrent.BlockingQueue> readQueueClass,
java.lang.Object... readQueueInitArgs) |
RWQueueRpcExecutor(java.lang.String name,
int handlerCount,
int numQueues,
float readShare,
int maxQueueLength,
Configuration conf,
Abortable abortable) |
RWQueueRpcExecutor(java.lang.String name,
int handlerCount,
int numQueues,
float readShare,
int maxQueueLength,
Configuration conf,
Abortable abortable,
java.lang.Class<? extends java.util.concurrent.BlockingQueue> readQueueClass,
java.lang.Object... readQueueInitArgs) |
SimpleRpcScheduler(Configuration conf,
int handlerCount,
int priorityHandlerCount,
int replicationHandlerCount,
PriorityFunction priority,
Abortable server,
int highPriorityLevel) |
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 | Class and Description |
---|---|
static class |
SweepJob.DummyMobAbortable |
Modifier and Type | Class and Description |
---|---|
class |
SimpleRSProcedureManager.SimpleSubprocedurePool |
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 |
Modifier and Type | Method and Description |
---|---|
RpcScheduler |
RpcSchedulerFactory.create(Configuration conf,
PriorityFunction priority,
Abortable server)
Constructs a
RpcScheduler . |
RpcScheduler |
SimpleRpcSchedulerFactory.create(Configuration conf,
PriorityFunction priority,
Abortable server) |
Modifier and Type | Class and Description |
---|---|
class |
HBaseReplicationEndpoint
A
BaseReplicationEndpoint for replication endpoints whose
target cluster is an HBase cluster. |
class |
ReplicationPeerZKImpl |
Modifier and Type | Field and Description |
---|---|
protected Abortable |
ReplicationStateZKBase.abortable |
Modifier and Type | Method and Description |
---|---|
static ReplicationPeers |
ReplicationFactory.getReplicationPeers(ZooKeeperWatcher zk,
Configuration conf,
Abortable abortable) |
static ReplicationQueues |
ReplicationFactory.getReplicationQueues(ZooKeeperWatcher zk,
Configuration conf,
Abortable abortable) |
static ReplicationQueuesClient |
ReplicationFactory.getReplicationQueuesClient(ZooKeeperWatcher zk,
Configuration conf,
Abortable abortable) |
static ReplicationTracker |
ReplicationFactory.getReplicationTracker(ZooKeeperWatcher zookeeper,
ReplicationPeers replicationPeers,
Configuration conf,
Abortable abortable,
Stoppable stopper) |
Constructor and Description |
---|
PeerStateTracker(java.lang.String peerStateZNode,
ZooKeeperWatcher watcher,
Abortable abortable) |
ReplicationPeersZKImpl(ZooKeeperWatcher zk,
Configuration conf,
Abortable abortable) |
ReplicationQueuesClientZKImpl(ZooKeeperWatcher zk,
Configuration conf,
Abortable abortable) |
ReplicationQueuesZKImpl(ZooKeeperWatcher zk,
Configuration conf,
Abortable abortable) |
ReplicationStateZKBase(ZooKeeperWatcher zookeeper,
Configuration conf,
Abortable abortable) |
ReplicationTrackerZKImpl(ZooKeeperWatcher zookeeper,
ReplicationPeers replicationPeers,
Configuration conf,
Abortable abortable,
Stoppable stopper) |
TableCFsTracker(java.lang.String tableCFsZNode,
ZooKeeperWatcher watcher,
Abortable abortable) |
Modifier and Type | Class and Description |
---|---|
class |
HBaseInterClusterReplicationEndpoint
A
ReplicationEndpoint
implementation for replicating to another HBase cluster. |
class |
RegionReplicaReplicationEndpoint
A
ReplicationEndpoint endpoint which receives the WAL edits from the
WAL, and sends the edits to replicas of regions. |
Modifier and Type | Class and Description |
---|---|
class |
ZooKeeperWatcher
Acts as the single ZooKeeper Watcher.
|
Modifier and Type | Field and Description |
---|---|
protected Abortable |
ZooKeeperNodeTracker.abortable
Used to abort if a fatal error occurs
|
protected Abortable |
ZooKeeperWatcher.abortable |
Constructor and Description |
---|
ClusterStatusTracker(ZooKeeperWatcher watcher,
Abortable abortable)
Creates a cluster status tracker.
|
DrainingServerTracker(ZooKeeperWatcher watcher,
Abortable abortable,
ServerManager serverManager) |
LoadBalancerTracker(ZooKeeperWatcher watcher,
Abortable abortable) |
MasterAddressTracker(ZooKeeperWatcher watcher,
Abortable abortable)
Construct a master address listener with the specified
zookeeper reference. |
RegionNormalizerTracker(ZooKeeperWatcher watcher,
Abortable abortable) |
SplitOrMergeTracker(ZooKeeperWatcher watcher,
Configuration conf,
Abortable abortable) |
ZKClusterId(ZooKeeperWatcher watcher,
Abortable abortable) |
ZooKeeperNodeTracker(ZooKeeperWatcher watcher,
java.lang.String node,
Abortable abortable)
Constructs a new ZK node tracker.
|
ZooKeeperWatcher(Configuration conf,
java.lang.String identifier,
Abortable abortable)
Instantiate a ZooKeeper connection and watcher.
|
ZooKeeperWatcher(Configuration conf,
java.lang.String identifier,
Abortable abortable,
boolean canCreateBaseZNode)
Instantiate a ZooKeeper connection and watcher.
|