Package | Description |
---|---|
org.apache.hadoop.hbase | |
org.apache.hadoop.hbase.backup | |
org.apache.hadoop.hbase.backup.regionserver | |
org.apache.hadoop.hbase.client |
Provides HBase Client
|
org.apache.hadoop.hbase.client.locking | |
org.apache.hadoop.hbase.coprocessor |
Table of Contents
|
org.apache.hadoop.hbase.ipc |
Tools to help define network clients and servers.
|
org.apache.hadoop.hbase.master | |
org.apache.hadoop.hbase.master.region | |
org.apache.hadoop.hbase.procedure.flush | |
org.apache.hadoop.hbase.regionserver | |
org.apache.hadoop.hbase.regionserver.snapshot | |
org.apache.hadoop.hbase.regionserver.wal | |
org.apache.hadoop.hbase.replication |
Multi Cluster Replication
|
org.apache.hadoop.hbase.replication.regionserver | |
org.apache.hadoop.hbase.thrift2.client | |
org.apache.hadoop.hbase.wal | |
org.apache.hadoop.hbase.zookeeper |
Modifier and Type | Interface and Description |
---|---|
interface |
Server
Defines a curated set of shared functions implemented by HBase servers (Masters and
RegionServers).
|
Modifier and Type | Class and Description |
---|---|
class |
HBaseServerBase<R extends HBaseRpcServicesBase<?>>
Base class for hbase services, such as master or region server.
|
static class |
MiniHBaseCluster.MiniHBaseClusterRegionServer
Deprecated.
Subclass so can get at protected methods (none at moment).
|
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 region server.
|
Modifier and Type | Interface and Description |
---|---|
interface |
Admin
The administrative API for HBase.
|
interface |
Connection
A cluster connection encapsulating lower level individual connections to actual servers and a
connection to zookeeper.
|
interface |
Hbck
Hbck fixup tool APIs.
|
Modifier and Type | Class and Description |
---|---|
(package private) class |
AdminOverAsyncAdmin
The
Admin implementation which is based on an AsyncAdmin . |
(package private) class |
ConnectionOverAsyncConnection
The connection implementation based on
AsyncConnection . |
class |
HBaseHbck
Use
Connection.getHbck() to obtain an instance of Hbck instead of constructing an
HBaseHbck directly. |
class |
SharedConnection
Wraps a
Connection to make it can't be closed or aborted. |
Modifier and Type | Field and Description |
---|---|
private Abortable |
EntityLock.abort |
Modifier and Type | Method and Description |
---|---|
EntityLock |
LockServiceClient.namespaceLock(String namespace,
String description,
Abortable abort)
LocCreate a new EntityLock object to acquire exclusive lock on a namespace.
|
EntityLock |
LockServiceClient.regionLock(List<RegionInfo> regionInfos,
String description,
Abortable abort)
Create a new EntityLock object to acquire exclusive lock on multiple regions of same tables.
|
EntityLock |
LockServiceClient.tableLock(TableName tableName,
boolean exclusive,
String description,
Abortable abort)
Create a new EntityLock object to acquire an exclusive or shared lock on a table.
|
Constructor and Description |
---|
EntityLock(org.apache.hadoop.conf.Configuration conf,
org.apache.hadoop.hbase.shaded.protobuf.generated.LockServiceProtos.LockService.BlockingInterface stub,
org.apache.hadoop.hbase.shaded.protobuf.generated.LockServiceProtos.LockRequest request,
Abortable abort)
Abortable.abort() is called when the lease of the lock will expire.
|
Modifier and Type | Field and Description |
---|---|
protected Abortable |
CoprocessorHost.abortable |
Constructor and Description |
---|
CoprocessorHost(Abortable abortable) |
Modifier and Type | Field and Description |
---|---|
(package private) Abortable |
RpcHandler.abortable |
private Abortable |
SimpleRpcScheduler.abortable |
private Abortable |
RpcExecutor.abortable |
Modifier and Type | Method and Description |
---|---|
protected RpcHandler |
FastPathBalancedQueueRpcExecutor.getHandler(String name,
double handlerFailureThreshhold,
int handlerCount,
BlockingQueue<CallRunner> q,
AtomicInteger activeHandlerCount,
AtomicInteger failedHandlerCount,
Abortable abortable) |
protected RpcHandler |
FastPathRWQueueRpcExecutor.getHandler(String name,
double handlerFailureThreshhold,
int handlerCount,
BlockingQueue<CallRunner> q,
AtomicInteger activeHandlerCount,
AtomicInteger failedHandlerCount,
Abortable abortable) |
protected RpcHandler |
RpcExecutor.getHandler(String name,
double handlerFailureThreshhold,
int handlerCount,
BlockingQueue<CallRunner> q,
AtomicInteger activeHandlerCount,
AtomicInteger failedHandlerCount,
Abortable abortable)
Override if providing alternate Handler implementation.
|
Constructor and Description |
---|
BalancedQueueRpcExecutor(String name,
int handlerCount,
int maxQueueLength,
PriorityFunction priority,
org.apache.hadoop.conf.Configuration conf,
Abortable abortable) |
BalancedQueueRpcExecutor(String name,
int handlerCount,
String callQueueType,
int maxQueueLength,
PriorityFunction priority,
org.apache.hadoop.conf.Configuration conf,
Abortable abortable) |
FastPathBalancedQueueRpcExecutor(String name,
int handlerCount,
int maxQueueLength,
PriorityFunction priority,
org.apache.hadoop.conf.Configuration conf,
Abortable abortable) |
FastPathBalancedQueueRpcExecutor(String name,
int handlerCount,
String callQueueType,
int maxQueueLength,
PriorityFunction priority,
org.apache.hadoop.conf.Configuration conf,
Abortable abortable) |
FastPathRpcHandler(String name,
double handlerFailureThreshhold,
int handlerCount,
BlockingQueue<CallRunner> q,
AtomicInteger activeHandlerCount,
AtomicInteger failedHandlerCount,
Abortable abortable,
Deque<FastPathRpcHandler> fastPathHandlerStack) |
FastPathRWQueueRpcExecutor(String name,
int handlerCount,
int maxQueueLength,
PriorityFunction priority,
org.apache.hadoop.conf.Configuration conf,
Abortable abortable) |
MetaRWQueueRpcExecutor(String name,
int handlerCount,
int maxQueueLength,
PriorityFunction priority,
org.apache.hadoop.conf.Configuration conf,
Abortable abortable) |
RpcExecutor(String name,
int handlerCount,
int maxQueueLength,
PriorityFunction priority,
org.apache.hadoop.conf.Configuration conf,
Abortable abortable) |
RpcExecutor(String name,
int handlerCount,
String callQueueType,
int maxQueueLength,
PriorityFunction priority,
org.apache.hadoop.conf.Configuration conf,
Abortable abortable) |
RpcHandler(String name,
double handlerFailureThreshhold,
int handlerCount,
BlockingQueue<CallRunner> q,
AtomicInteger activeHandlerCount,
AtomicInteger failedHandlerCount,
Abortable abortable) |
RWQueueRpcExecutor(String name,
int handlerCount,
int maxQueueLength,
PriorityFunction priority,
org.apache.hadoop.conf.Configuration conf,
Abortable abortable) |
SimpleRpcScheduler(org.apache.hadoop.conf.Configuration conf,
int handlerCount,
int priorityHandlerCount,
int replicationHandlerCount,
int metaTransitionHandler,
PriorityFunction priority,
Abortable server,
int highPriorityLevel) |
Modifier and Type | Interface and Description |
---|---|
interface |
MasterServices
A curated subset of services provided by
HMaster . |
Modifier and Type | Class and Description |
---|---|
class |
HMaster
HMaster is the "master server" for HBase.
|
static class |
HMasterCommandLine.LocalHMaster |
Modifier and Type | Field and Description |
---|---|
private Abortable |
MasterRegionServerList.abortable |
private Abortable |
DrainingServerTracker.abortable |
Constructor and Description |
---|
DrainingServerTracker(ZKWatcher watcher,
Abortable abortable,
ServerManager serverManager) |
MasterRegionServerList(MasterRegion region,
Abortable abortable) |
Modifier and Type | Field and Description |
---|---|
private Abortable |
MasterRegionFlusherAndCompactor.abortable |
Modifier and Type | Method and Description |
---|---|
(package private) static MasterRegionWALRoller |
MasterRegionWALRoller.create(String name,
org.apache.hadoop.conf.Configuration conf,
Abortable abortable,
org.apache.hadoop.fs.FileSystem fs,
org.apache.hadoop.fs.Path walRootDir,
org.apache.hadoop.fs.Path globalWALRootDir,
String archivedWALSuffix,
long rollPeriodMs,
long flushSize) |
Constructor and Description |
---|
MasterRegionFlusherAndCompactor(org.apache.hadoop.conf.Configuration conf,
Abortable abortable,
HRegion region,
long flushSize,
long flushPerChanges,
long flushIntervalMs,
int compactMin,
org.apache.hadoop.fs.Path globalArchivePath,
String archivedHFileSuffix) |
MasterRegionWALRoller(String name,
org.apache.hadoop.conf.Configuration conf,
Abortable abortable,
org.apache.hadoop.fs.FileSystem fs,
org.apache.hadoop.fs.Path walRootDir,
org.apache.hadoop.fs.Path globalWALRootDir,
String archivedWALSuffix) |
Modifier and Type | Field and Description |
---|---|
private Abortable |
RegionServerFlushTableProcedureManager.FlushTableSubprocedurePool.abortable |
Constructor and Description |
---|
FlushTableSubprocedurePool(String name,
org.apache.hadoop.conf.Configuration conf,
Abortable abortable) |
Modifier and Type | Interface and Description |
---|---|
interface |
RegionServerServices
A curated subset of services provided by
HRegionServer . |
Modifier and Type | Class and Description |
---|---|
class |
HRegionServer
HRegionServer makes a set of HRegions available to clients.
|
Modifier and Type | Method and Description |
---|---|
RpcScheduler |
FifoRpcSchedulerFactory.create(org.apache.hadoop.conf.Configuration conf,
PriorityFunction priority,
Abortable server) |
RpcScheduler |
RpcSchedulerFactory.create(org.apache.hadoop.conf.Configuration conf,
PriorityFunction priority,
Abortable server)
Constructs a
RpcScheduler . |
RpcScheduler |
SimpleRpcSchedulerFactory.create(org.apache.hadoop.conf.Configuration conf,
PriorityFunction priority,
Abortable server) |
RpcScheduler |
MasterFifoRpcSchedulerFactory.create(org.apache.hadoop.conf.Configuration conf,
PriorityFunction priority,
Abortable server) |
EntityLock |
HRegionServer.regionLock(List<RegionInfo> regionInfo,
String description,
Abortable abort) |
EntityLock |
RegionServerServices.regionLock(List<RegionInfo> regionInfos,
String description,
Abortable abort)
Master based locks on namespaces/tables/regions.
|
Modifier and Type | Field and Description |
---|---|
private Abortable |
RegionServerSnapshotManager.SnapshotSubprocedurePool.abortable |
Constructor and Description |
---|
SnapshotSubprocedurePool(String name,
org.apache.hadoop.conf.Configuration conf,
Abortable abortable) |
Modifier and Type | Field and Description |
---|---|
protected Abortable |
AbstractFSWAL.abortable |
Constructor and Description |
---|
AbstractFSWAL(org.apache.hadoop.fs.FileSystem fs,
Abortable abortable,
org.apache.hadoop.fs.Path rootDir,
String logDir,
String archiveDir,
org.apache.hadoop.conf.Configuration conf,
List<WALActionsListener> listeners,
boolean failIfWALExists,
String prefix,
String suffix,
org.apache.hadoop.fs.FileSystem remoteFs,
org.apache.hadoop.fs.Path remoteWALDir) |
AsyncFSWAL(org.apache.hadoop.fs.FileSystem fs,
Abortable abortable,
org.apache.hadoop.fs.Path rootDir,
String logDir,
String archiveDir,
org.apache.hadoop.conf.Configuration conf,
List<WALActionsListener> listeners,
boolean failIfWALExists,
String prefix,
String suffix,
org.apache.hadoop.fs.FileSystem remoteFs,
org.apache.hadoop.fs.Path remoteWALDir,
org.apache.hbase.thirdparty.io.netty.channel.EventLoopGroup eventLoopGroup,
Class<? extends org.apache.hbase.thirdparty.io.netty.channel.Channel> channelClass,
StreamSlowMonitor monitor) |
FSHLog(org.apache.hadoop.fs.FileSystem fs,
Abortable abortable,
org.apache.hadoop.fs.Path root,
String logDir,
org.apache.hadoop.conf.Configuration conf) |
FSHLog(org.apache.hadoop.fs.FileSystem fs,
Abortable abortable,
org.apache.hadoop.fs.Path rootDir,
String logDir,
String archiveDir,
org.apache.hadoop.conf.Configuration conf,
List<WALActionsListener> listeners,
boolean failIfWALExists,
String prefix,
String suffix,
org.apache.hadoop.fs.FileSystem remoteFs,
org.apache.hadoop.fs.Path remoteWALDir)
Create an edit log at the given
dir location. |
Modifier and Type | Class and Description |
---|---|
class |
HBaseReplicationEndpoint
A
BaseReplicationEndpoint for replication endpoints whose target cluster is an HBase
cluster. |
Modifier and Type | Field and Description |
---|---|
private Abortable |
ReplicationEndpoint.Context.abortable |
Modifier and Type | Method and Description |
---|---|
Abortable |
ReplicationEndpoint.Context.getAbortable() |
Constructor and Description |
---|
Context(Server server,
org.apache.hadoop.conf.Configuration localConf,
org.apache.hadoop.conf.Configuration conf,
org.apache.hadoop.fs.FileSystem fs,
String peerId,
UUID clusterId,
ReplicationPeer replicationPeer,
MetricsSource metrics,
TableDescriptors tableDescriptors,
Abortable abortable) |
Modifier and Type | Class and Description |
---|---|
class |
HBaseInterClusterReplicationEndpoint
A
ReplicationEndpoint implementation for replicating
to another HBase cluster. |
private static class |
ReplicationSyncUp.DummyServer |
Modifier and Type | Class and Description |
---|---|
class |
ThriftAdmin |
class |
ThriftConnection |
Modifier and Type | Class and Description |
---|---|
class |
AbstractWALRoller<T extends Abortable>
Runs periodically to determine if the WAL should be rolled.
|
Modifier and Type | Field and Description |
---|---|
protected Abortable |
AbstractWALProvider.abortable |
protected T |
AbstractWALRoller.abortable |
(package private) Abortable |
WALFactory.abortable |
private Abortable |
LazyInitializedWALProvider.abortable |
Modifier and Type | Method and Description |
---|---|
void |
AbstractWALProvider.init(WALFactory factory,
org.apache.hadoop.conf.Configuration conf,
String providerId,
Abortable server) |
void |
DisabledWALProvider.init(WALFactory factory,
org.apache.hadoop.conf.Configuration conf,
String providerId,
Abortable abortable) |
void |
WALProvider.init(WALFactory factory,
org.apache.hadoop.conf.Configuration conf,
String providerId,
Abortable server)
Set up the provider to create wals.
|
Constructor and Description |
---|
LazyInitializedWALProvider(WALFactory factory,
String providerId,
String providerConfigName,
Abortable abortable) |
WALFactory(org.apache.hadoop.conf.Configuration conf,
ServerName serverName,
Abortable abortable)
Create a WALFactory.
|
WALFactory(org.apache.hadoop.conf.Configuration conf,
String factoryId,
Abortable abortable) |
Modifier and Type | Class and Description |
---|---|
class |
ZKWatcher
Acts as the single ZooKeeper Watcher.
|
Modifier and Type | Field and Description |
---|---|
protected Abortable |
ZKWatcher.abortable |
private Abortable |
ZKClusterId.abortable |
protected Abortable |
ZKNodeTracker.abortable
Used to abort if a fatal error occurs
|
Constructor and Description |
---|
ClusterStatusTracker(ZKWatcher watcher,
Abortable abortable)
Creates a cluster status tracker.
|
MasterAddressTracker(ZKWatcher watcher,
Abortable abortable)
Construct a master address listener with the specified
zookeeper reference. |
ZKClusterId(ZKWatcher watcher,
Abortable abortable) |
ZKNodeTracker(ZKWatcher watcher,
String node,
Abortable abortable)
Constructs a new ZK node tracker.
|
ZKWatcher(org.apache.hadoop.conf.Configuration conf,
String identifier,
Abortable abortable)
Instantiate a ZooKeeper connection and watcher.
|
ZKWatcher(org.apache.hadoop.conf.Configuration conf,
String identifier,
Abortable abortable,
boolean canCreateBaseZNode)
Instantiate a ZooKeeper connection and watcher.
|
ZKWatcher(org.apache.hadoop.conf.Configuration conf,
String identifier,
Abortable abortable,
boolean canCreateBaseZNode,
boolean clientZK)
Instantiate a ZooKeeper connection and watcher.
|
Copyright © 2007–2020 The Apache Software Foundation. All rights reserved.