Package | Description |
---|---|
org.apache.hadoop.hbase.client |
Provides HBase Client
|
org.apache.hadoop.hbase.ipc |
Tools to help define network clients and servers.
|
org.apache.hadoop.hbase.master | |
org.apache.hadoop.hbase.regionserver | |
org.apache.hadoop.hbase.regionserver.handler | |
org.apache.hadoop.hbase.replication.regionserver | |
org.apache.hadoop.hbase.tool |
Modifier and Type | Field and Description |
---|---|
private RpcControllerFactory |
HTable.rpcControllerFactory |
private RpcControllerFactory |
ConnectionImplementation.rpcControllerFactory |
private RpcControllerFactory |
HBaseHbck.rpcControllerFactory |
(package private) RpcControllerFactory |
AsyncConnectionImpl.rpcControllerFactory |
protected RpcControllerFactory |
ClientScanner.rpcControllerFactory |
private RpcControllerFactory |
SecureBulkLoadClient.rpcControllerFactory |
protected RpcControllerFactory |
ScannerCallable.rpcControllerFactory |
private RpcControllerFactory |
AbstractRpcBasedConnectionRegistry.rpcControllerFactory |
protected RpcControllerFactory |
RegionAdminServiceCallable.rpcControllerFactory |
private RpcControllerFactory |
RpcRetryingCallerWithReadReplicas.rpcControllerFactory |
private RpcControllerFactory |
HBaseAdmin.rpcControllerFactory |
(package private) RpcControllerFactory |
AsyncProcess.rpcFactory |
Modifier and Type | Method and Description |
---|---|
RpcControllerFactory |
ClusterConnection.getRpcControllerFactory()
Returns Connection's RpcControllerFactory instance
|
RpcControllerFactory |
ConnectionImplementation.getRpcControllerFactory() |
private RpcControllerFactory |
HBaseAdmin.getRpcControllerFactory() |
Modifier and Type | Method and Description |
---|---|
(package private) static HTableDescriptor |
HBaseAdmin.getHTableDescriptor(TableName tableName,
Connection connection,
RpcRetryingCallerFactory rpcCallerFactory,
RpcControllerFactory rpcControllerFactory,
int operationTimeout,
int rpcTimeout)
Deprecated.
since 2.0 version and will be removed in 3.0 version. use
HBaseAdmin.getTableDescriptor(TableName, Connection, RpcRetryingCallerFactory,RpcControllerFactory,int,int) |
(package private) static TableDescriptor |
HBaseAdmin.getTableDescriptor(TableName tableName,
Connection connection,
RpcRetryingCallerFactory rpcCallerFactory,
RpcControllerFactory rpcControllerFactory,
int operationTimeout,
int rpcTimeout) |
Constructor and Description |
---|
AsyncProcess(ClusterConnection hc,
org.apache.hadoop.conf.Configuration conf,
RpcRetryingCallerFactory rpcCaller,
RpcControllerFactory rpcFactory) |
AsyncProcess(ClusterConnection hc,
org.apache.hadoop.conf.Configuration conf,
RpcRetryingCallerFactory rpcCaller,
RpcControllerFactory rpcFactory,
int retriesNumber) |
BufferedMutatorImpl(ClusterConnection conn,
RpcRetryingCallerFactory rpcCallerFactory,
RpcControllerFactory rpcFactory,
BufferedMutatorParams params) |
ClientAsyncPrefetchScanner(org.apache.hadoop.conf.Configuration configuration,
Scan scan,
TableName name,
ClusterConnection connection,
RpcRetryingCallerFactory rpcCallerFactory,
RpcControllerFactory rpcControllerFactory,
ExecutorService pool,
int scanReadRpcTimeout,
int scannerTimeout,
int replicaCallTimeoutMicroSecondScan) |
ClientScanner(org.apache.hadoop.conf.Configuration conf,
Scan scan,
TableName tableName,
ClusterConnection connection,
RpcRetryingCallerFactory rpcFactory,
RpcControllerFactory controllerFactory,
ExecutorService pool,
int scanReadRpcTimeout,
int scannerTimeout,
int primaryOperationTimeout)
Create a new ClientScanner for the specified table Note that the passed
Scan 's start
row maybe changed changed. |
ClientSimpleScanner(org.apache.hadoop.conf.Configuration configuration,
Scan scan,
TableName name,
ClusterConnection connection,
RpcRetryingCallerFactory rpcCallerFactory,
RpcControllerFactory rpcControllerFactory,
ExecutorService pool,
int scanReadRpcTimeout,
int scannerTimeout,
int replicaCallTimeoutMicroSecondScan) |
FlushRegionCallable(ClusterConnection connection,
RpcControllerFactory rpcControllerFactory,
RegionInfo regionInfo,
boolean writeFlushWalMarker) |
FlushRegionCallable(ClusterConnection connection,
RpcControllerFactory rpcControllerFactory,
TableName tableName,
byte[] regionName,
byte[] regionStartKey,
boolean writeFlushWalMarker) |
HBaseHbck(org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.HbckService.BlockingInterface hbck,
RpcControllerFactory rpcControllerFactory) |
HTable(ConnectionImplementation connection,
TableBuilderBase builder,
RpcRetryingCallerFactory rpcCallerFactory,
RpcControllerFactory rpcControllerFactory,
ExecutorService pool)
Creates an object to access a HBase table.
|
MasterCallable(Connection connection,
RpcControllerFactory rpcConnectionFactory) |
RegionAdminServiceCallable(ClusterConnection connection,
RpcControllerFactory rpcControllerFactory,
HRegionLocation location,
TableName tableName,
byte[] row) |
RegionAdminServiceCallable(ClusterConnection connection,
RpcControllerFactory rpcControllerFactory,
HRegionLocation location,
TableName tableName,
byte[] row,
int replicaId) |
RegionAdminServiceCallable(ClusterConnection connection,
RpcControllerFactory rpcControllerFactory,
TableName tableName,
byte[] row) |
ReversedClientScanner(org.apache.hadoop.conf.Configuration conf,
Scan scan,
TableName tableName,
ClusterConnection connection,
RpcRetryingCallerFactory rpcFactory,
RpcControllerFactory controllerFactory,
ExecutorService pool,
int scanReadRpcTimeout,
int scannerTimeout,
int primaryOperationTimeout)
Create a new ReversibleClientScanner for the specified table Note that the passed
Scan 's start row maybe changed. |
ReversedScannerCallable(ClusterConnection connection,
TableName tableName,
Scan scan,
ScanMetrics scanMetrics,
RpcControllerFactory rpcFactory,
int replicaId) |
RpcRetryingCallerWithReadReplicas(RpcControllerFactory rpcControllerFactory,
TableName tableName,
ClusterConnection cConnection,
Get get,
ExecutorService pool,
int retries,
int operationTimeout,
int rpcTimeout,
int timeBeforeReplicas) |
ScannerCallable(ClusterConnection connection,
TableName tableName,
Scan scan,
ScanMetrics scanMetrics,
RpcControllerFactory rpcControllerFactory,
int id) |
Modifier and Type | Method and Description |
---|---|
static RpcControllerFactory |
RpcControllerFactory.instantiate(org.apache.hadoop.conf.Configuration configuration) |
Modifier and Type | Field and Description |
---|---|
private RpcControllerFactory |
ServerManager.rpcControllerFactory |
Modifier and Type | Field and Description |
---|---|
private RpcControllerFactory |
HRegionServer.rpcControllerFactory |
Modifier and Type | Field and Description |
---|---|
private RpcControllerFactory |
RegionReplicaFlushHandler.rpcControllerFactory |
Constructor and Description |
---|
RegionReplicaFlushHandler(Server server,
ClusterConnection connection,
RpcRetryingCallerFactory rpcRetryingCallerFactory,
RpcControllerFactory rpcControllerFactory,
int operationTimeout,
HRegion region) |
Modifier and Type | Field and Description |
---|---|
(package private) RpcControllerFactory |
RegionReplicaReplicationEndpoint.RegionReplicaSinkWriter.rpcControllerFactory |
Constructor and Description |
---|
RegionReplicaReplayCallable(ClusterConnection connection,
RpcControllerFactory rpcControllerFactory,
TableName tableName,
HRegionLocation location,
RegionInfo regionInfo,
byte[] row,
List<WAL.Entry> entries,
AtomicLong skippedEntries) |
Modifier and Type | Field and Description |
---|---|
private RpcControllerFactory |
LoadIncrementalHFiles.rpcControllerFactory
Deprecated.
|
Copyright © 2007–2020 The Apache Software Foundation. All rights reserved.