Package | Description |
---|---|
org.apache.hadoop.hbase | |
org.apache.hadoop.hbase.backup.example | |
org.apache.hadoop.hbase.client |
Provides HBase Client
|
org.apache.hadoop.hbase.ipc | |
org.apache.hadoop.hbase.master | |
org.apache.hadoop.hbase.regionserver | |
org.apache.hadoop.hbase.regionserver.handler |
Modifier and Type | Method and Description |
---|---|
ClusterConnection |
Server.getConnection()
Returns a reference to the servers' cluster connection.
|
ClusterConnection |
MockRegionServerServices.getConnection() |
Constructor and Description |
---|
ZKTableArchiveClient(Configuration conf,
ClusterConnection connection) |
Modifier and Type | Class and Description |
---|---|
class |
CoprocessorHConnection
Connection to an HTable from within a Coprocessor.
|
Modifier and Type | Field and Description |
---|---|
protected ClusterConnection |
RpcRetryingCallerWithReadReplicas.cConnection |
protected ClusterConnection |
ScannerCallable.cConnection |
protected ClusterConnection |
BufferedMutatorImpl.connection |
protected ClusterConnection |
HTable.connection |
protected ClusterConnection |
RegionAdminServiceCallable.connection |
Modifier and Type | Method and Description |
---|---|
static ClusterConnection |
ConnectionUtils.createShortCircuitHConnection(Connection conn,
ServerName serverName,
AdminProtos.AdminService.BlockingInterface admin,
ClientProtos.ClientService.BlockingInterface client)
Adapt a HConnection so that it can bypass the RPC layer (serialization,
deserialization, networking, etc..) -- i.e.
|
protected ClusterConnection |
ClientScanner.getConnection() |
ClusterConnection |
ScannerCallable.getConnection() |
static ClusterConnection |
CoprocessorHConnection.getConnectionForEnvironment(CoprocessorEnvironment env)
Create an unmanaged
HConnection based on the environment in which we are running the
coprocessor. |
static ClusterConnection |
HConnectionTestingUtility.getMockedConnection(Configuration conf)
Get a Mocked
HConnection that goes with the passed conf
configuration instance. |
static ClusterConnection |
HConnectionTestingUtility.getMockedConnectionAndDecorate(Configuration conf,
AdminProtos.AdminService.BlockingInterface admin,
ClientProtos.ClientService.BlockingInterface client,
ServerName sn,
HRegionInfo hri)
Calls
HConnectionTestingUtility.getMockedConnection(Configuration) and then mocks a few
more of the popular ClusterConnection methods so they do 'normal'
operation (see return doc below for list). |
static ClusterConnection |
HConnectionTestingUtility.getSpiedClusterConnection(Configuration conf) |
static ClusterConnection |
HConnectionTestingUtility.getSpiedConnection(Configuration conf)
Get a Mockito spied-upon
ClusterConnection that goes with the passed
conf configuration instance. |
Modifier and Type | Method and Description |
---|---|
org.apache.hadoop.hbase.client.ScannerCallableWithReplicas |
ClientSmallScanner.SmallScannerCallableFactory.getCallable(ClusterConnection connection,
TableName table,
Scan scan,
ScanMetrics scanMetrics,
byte[] localStartKey,
int cacheNum,
RpcControllerFactory controllerFactory,
java.util.concurrent.ExecutorService pool,
int primaryOperationTimeout,
int retries,
int scannerTimeout,
Configuration conf,
RpcRetryingCaller<Result[]> caller) |
org.apache.hadoop.hbase.client.ScannerCallableWithReplicas |
ClientSmallReversedScanner.SmallReversedScannerCallableFactory.getCallable(ClusterConnection connection,
TableName table,
Scan scan,
ScanMetrics scanMetrics,
byte[] localStartKey,
int cacheNum,
RpcControllerFactory controllerFactory,
java.util.concurrent.ExecutorService pool,
int primaryOperationTimeout,
int retries,
int scannerTimeout,
Configuration conf,
RpcRetryingCaller<Result[]> caller,
boolean isFirstRegionToLocate) |
static QuotaProtos.GetQuotaStatesResponse |
QuotaStatusCalls.getMasterQuotaStates(ClusterConnection clusterConn,
int timeout)
|
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 clusterConn,
int timeout)
|
static QuotaProtos.GetSpaceQuotaRegionSizesResponse |
QuotaStatusCalls.getMasterRegionSizes(ClusterConnection conn,
RpcControllerFactory factory,
RpcRetryingCallerFactory rpcCaller,
int timeout) |
static RegionLocations |
RegionAdminServiceCallable.getRegionLocations(ClusterConnection connection,
TableName tableName,
byte[] row,
boolean useCache,
int replicaId) |
static QuotaProtos.GetSpaceQuotaSnapshotsResponse |
QuotaStatusCalls.getRegionServerQuotaSnapshot(ClusterConnection clusterConn,
int timeout,
ServerName sn)
|
static QuotaProtos.GetSpaceQuotaSnapshotsResponse |
QuotaStatusCalls.getRegionServerQuotaSnapshot(ClusterConnection conn,
RpcControllerFactory factory,
int timeout,
ServerName sn) |
static NonceGenerator |
ConnectionUtils.injectNonceGeneratorForTesting(ClusterConnection conn,
NonceGenerator cnm) |
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.
|
CoprocessorHConnection(ClusterConnection delegate,
HRegionServer server)
Deprecated.
delegate is not used
|
FlushRegionCallable(ClusterConnection connection,
RpcControllerFactory rpcControllerFactory,
HRegionInfo regionInfo,
boolean writeFlushWalMarker) |
FlushRegionCallable(ClusterConnection connection,
RpcControllerFactory rpcControllerFactory,
TableName tableName,
byte[] regionName,
byte[] regionStartKey,
boolean writeFlushWalMarker) |
HRegionLocator(TableName tableName,
ClusterConnection connection) |
HTable(ClusterConnection conn,
BufferedMutatorParams params)
For internal testing.
|
HTable(TableName tableName,
ClusterConnection connection,
ConnectionConfiguration tableConfig,
RpcRetryingCallerFactory rpcCallerFactory,
RpcControllerFactory rpcControllerFactory,
java.util.concurrent.ExecutorService pool)
Creates an object to access a HBase table.
|
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(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. |
ReversedScannerCallable(ClusterConnection connection,
TableName tableName,
Scan scan,
ScanMetrics scanMetrics,
byte[] locateStartRow)
|
ReversedScannerCallable(ClusterConnection connection,
TableName tableName,
Scan scan,
ScanMetrics scanMetrics,
byte[] locateStartRow,
RpcControllerFactory rpcFactory) |
ReversedScannerCallable(ClusterConnection connection,
TableName tableName,
Scan scan,
ScanMetrics scanMetrics,
byte[] locateStartRow,
RpcControllerFactory rpcFactory,
int replicaId) |
RpcRetryingCallerWithReadReplicas(RpcControllerFactory rpcControllerFactory,
TableName tableName,
ClusterConnection cConnection,
Get get,
java.util.concurrent.ExecutorService pool,
int retries,
int callTimeout,
int timeBeforeReplicas) |
ScannerCallable(ClusterConnection connection,
TableName tableName,
Scan scan,
ScanMetrics scanMetrics,
RpcControllerFactory rpcControllerFactory) |
ScannerCallable(ClusterConnection connection,
TableName tableName,
Scan scan,
ScanMetrics scanMetrics,
RpcControllerFactory rpcControllerFactory,
int id) |
Constructor and Description |
---|
MasterCoprocessorRpcChannel(ClusterConnection conn) |
RegionCoprocessorRpcChannel(ClusterConnection conn,
TableName table,
byte[] row) |
RegionServerCoprocessorRpcChannel(ClusterConnection conn,
ServerName serverName) |
Modifier and Type | Method and Description |
---|---|
ClusterConnection |
TestActiveMasterManager.DummyMaster.getConnection() |
Modifier and Type | Method and Description |
---|---|
static void |
ServerManager.closeRegionSilentlyAndWait(ClusterConnection connection,
ServerName server,
HRegionInfo region,
long timeout)
Contacts a region server and waits up to timeout ms
to close the region.
|
Modifier and Type | Field and Description |
---|---|
protected ClusterConnection |
HRegionServer.clusterConnection
Cluster connection to be shared by services.
|
Modifier and Type | Method and Description |
---|---|
protected ClusterConnection |
HRegionServer.createClusterConnection()
Create a 'smarter' HConnection, one that is capable of by-passing RPC if the request is to
the local server.
|
ClusterConnection |
HRegionServer.getConnection() |
Constructor and Description |
---|
RegionReplicaFlushHandler(Server server,
ClusterConnection connection,
RpcRetryingCallerFactory rpcRetryingCallerFactory,
RpcControllerFactory rpcControllerFactory,
int operationTimeout,
HRegion region) |