Package | Description |
---|---|
org.apache.hadoop.hbase.client |
Provides HBase Client
|
org.apache.hadoop.hbase.regionserver.handler |
Modifier and Type | Class and Description |
---|---|
static class |
TestClientScanner.MockRpcRetryingCallerFactory |
Modifier and Type | Method and Description |
---|---|
RpcRetryingCallerFactory |
ClusterConnection.getNewRpcRetryingCallerFactory(Configuration conf)
Returns a new RpcRetryingCallerFactory from the given
Configuration . |
RpcRetryingCallerFactory |
ClusterConnection.getRpcRetryingCallerFactory() |
static RpcRetryingCallerFactory |
RpcRetryingCallerFactory.instantiate(Configuration configuration) |
static RpcRetryingCallerFactory |
RpcRetryingCallerFactory.instantiate(Configuration configuration,
org.apache.hadoop.hbase.client.RetryingCallerInterceptor interceptor,
ServerStatisticTracker stats) |
static RpcRetryingCallerFactory |
RpcRetryingCallerFactory.instantiate(Configuration configuration,
ServerStatisticTracker stats) |
Modifier and Type | Method and Description |
---|---|
static QuotaProtos.GetQuotaStatesResponse |
QuotaStatusCalls.getMasterQuotaStates(ClusterConnection conn,
RpcControllerFactory factory,
RpcRetryingCallerFactory rpcCaller,
int timeout)
Executes an RPC tot he HBase master to fetch its view on space quotas.
|
static QuotaProtos.GetSpaceQuotaRegionSizesResponse |
QuotaStatusCalls.getMasterRegionSizes(ClusterConnection conn,
RpcControllerFactory factory,
RpcRetryingCallerFactory rpcCaller,
int timeout) |
Constructor and Description |
---|
ClientScanner(Configuration conf,
Scan scan,
TableName tableName,
ClusterConnection connection,
RpcRetryingCallerFactory rpcFactory,
RpcControllerFactory controllerFactory,
java.util.concurrent.ExecutorService pool,
int primaryOperationTimeout)
Create a new ClientScanner for the specified table Note that the passed
Scan 's start
row maybe changed changed. |
ClientSmallReversedScanner(Configuration conf,
Scan scan,
TableName tableName,
ClusterConnection connection,
RpcRetryingCallerFactory rpcFactory,
RpcControllerFactory controllerFactory,
java.util.concurrent.ExecutorService pool,
int primaryOperationTimeout)
Create a new ReversibleClientScanner for the specified table.
|
ClientSmallScanner(Configuration conf,
Scan scan,
TableName tableName,
ClusterConnection connection,
RpcRetryingCallerFactory rpcFactory,
RpcControllerFactory controllerFactory,
java.util.concurrent.ExecutorService pool,
int primaryOperationTimeout)
Create a new ShortClientScanner for the specified table.
|
HTable(TableName tableName,
ClusterConnection connection,
ConnectionConfiguration tableConfig,
RpcRetryingCallerFactory rpcCallerFactory,
RpcControllerFactory rpcControllerFactory,
java.util.concurrent.ExecutorService pool)
Creates an object to access a HBase table.
|
ResultBoundedCompletionService(RpcRetryingCallerFactory retryingCallerFactory,
java.util.concurrent.Executor executor,
int maxTasks) |
ReversedClientScanner(Configuration conf,
Scan scan,
TableName tableName,
ClusterConnection connection,
RpcRetryingCallerFactory rpcFactory,
RpcControllerFactory controllerFactory,
java.util.concurrent.ExecutorService pool,
int primaryOperationTimeout)
Create a new ReversibleClientScanner for the specified table Note that the
passed
Scan 's start row maybe changed. |
Constructor and Description |
---|
RegionReplicaFlushHandler(Server server,
ClusterConnection connection,
RpcRetryingCallerFactory rpcRetryingCallerFactory,
RpcControllerFactory rpcControllerFactory,
int operationTimeout,
HRegion region) |