Package | Description |
---|---|
org.apache.hadoop.hbase | |
org.apache.hadoop.hbase.ipc |
Tools to help define network clients and servers.
|
org.apache.hadoop.hbase.master | |
org.apache.hadoop.hbase.regionserver |
Modifier and Type | Class and Description |
---|---|
class |
HBaseRpcServicesBase<S extends HBaseServerBase<?>>
Base class for Master and RegionServer RpcServices.
|
Modifier and Type | Field and Description |
---|---|
protected PriorityFunction |
HBaseRpcServicesBase.priority |
Modifier and Type | Method and Description |
---|---|
protected abstract PriorityFunction |
HBaseRpcServicesBase.createPriority() |
Modifier and Type | Class and Description |
---|---|
class |
AnnotationReadingPriorityFunction<T extends HBaseRpcServicesBase<?>>
Reads special method annotations and table names to figure a priority for use by QoS facility in
ipc; e.g: rpcs to hbase:meta get priority.
|
Modifier and Type | Field and Description |
---|---|
protected PriorityFunction |
PluggableBlockingQueue.priority |
private PriorityFunction |
SimpleRpcScheduler.priority |
private PriorityFunction |
RpcExecutor.CallPriorityComparator.priority |
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) |
CallPriorityComparator(org.apache.hadoop.conf.Configuration conf,
PriorityFunction priority) |
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) |
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) |
PluggableBlockingQueue(int maxQueueLength,
PriorityFunction priority,
org.apache.hadoop.conf.Configuration conf) |
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) |
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) |
SimpleRpcScheduler(org.apache.hadoop.conf.Configuration conf,
int handlerCount,
int priorityHandlerCount,
int replicationHandlerCount,
PriorityFunction priority,
int highPriorityLevel) |
Modifier and Type | Class and Description |
---|---|
class |
MasterAnnotationReadingPriorityFunction
Priority function specifically for the master.
|
class |
MasterRpcServices
Implements the master RPC services.
|
Modifier and Type | Method and Description |
---|---|
protected PriorityFunction |
MasterRpcServices.createPriority() |
Modifier and Type | Class and Description |
---|---|
(package private) class |
RSAnnotationReadingPriorityFunction
Priority function specifically for the region server.
|
class |
RSRpcServices
Implements the regionserver RPC services.
|
Modifier and Type | Method and Description |
---|---|
protected PriorityFunction |
RSRpcServices.createPriority() |
(package private) PriorityFunction |
RSRpcServices.getPriority() |
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 |
MasterFifoRpcSchedulerFactory.create(org.apache.hadoop.conf.Configuration conf,
PriorityFunction priority,
Abortable server) |
RpcScheduler |
SimpleRpcSchedulerFactory.create(org.apache.hadoop.conf.Configuration conf,
PriorityFunction priority,
Abortable server) |
Copyright © 2007–2020 The Apache Software Foundation. All rights reserved.