Package | Description |
---|---|
org.apache.hadoop.hbase | |
org.apache.hadoop.hbase.client |
Provides HBase Client
|
org.apache.hadoop.hbase.master | |
org.apache.hadoop.hbase.protobuf |
Holds classes generated from protobuf
src/main/protobuf definition files. |
org.apache.hadoop.hbase.protobuf.generated | |
org.apache.hadoop.hbase.regionserver |
Modifier and Type | Method and Description |
---|---|
ClientProtos.ClientService.BlockingInterface |
DistributedHBaseCluster.getClientProtocol(ServerName serverName) |
abstract ClientProtos.ClientService.BlockingInterface |
HBaseCluster.getClientProtocol(ServerName serverName)
Returns a ClientProtocol interface to the regionserver
|
ClientProtos.ClientService.BlockingInterface |
MiniHBaseCluster.getClientProtocol(ServerName serverName) |
Modifier and Type | Method and Description |
---|---|
ClientProtos.ClientService.BlockingInterface |
ClusterConnection.getClient(ServerName serverName)
Establishes a connection to the region server at the specified address, and returns
a region client protocol.
|
ClientProtos.ClientService.BlockingInterface |
HConnection.getClient(ServerName serverName)
Deprecated.
internal method, do not use thru HConnection
|
ClientProtos.ClientService.BlockingInterface |
CoprocessorHConnection.getClient(ServerName serverName) |
protected ClientProtos.ClientService.BlockingInterface |
RegionServerCallable.getStub() |
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.
|
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). |
Modifier and Type | Class and Description |
---|---|
class |
MasterRpcServices
Implements the master RPC services.
|
Modifier and Type | Method and Description |
---|---|
static boolean |
ProtobufUtil.bulkLoadHFile(ClientProtos.ClientService.BlockingInterface client,
java.util.List<Pair<byte[],java.lang.String>> familyPaths,
byte[] regionName,
boolean assignSeqNum)
A helper to bulk load a list of HFiles using client protocol.
|
static ClientProtos.CoprocessorServiceResponse |
ProtobufUtil.execRegionServerService(RpcController controller,
ClientProtos.ClientService.BlockingInterface client,
ClientProtos.CoprocessorServiceCall call)
Make a region server endpoint call
|
static ClientProtos.CoprocessorServiceResponse |
ProtobufUtil.execService(RpcController controller,
ClientProtos.ClientService.BlockingInterface client,
ClientProtos.CoprocessorServiceCall call,
byte[] regionName) |
static Result |
ProtobufUtil.getRowOrBefore(ClientProtos.ClientService.BlockingInterface client,
byte[] regionName,
byte[] row,
byte[] family)
Deprecated.
since 0.99 - use reversed scanner instead.
|
Modifier and Type | Method and Description |
---|---|
static ClientProtos.ClientService.BlockingInterface |
ClientProtos.ClientService.newBlockingStub(com.google.protobuf.BlockingRpcChannel channel) |
Modifier and Type | Method and Description |
---|---|
static com.google.protobuf.BlockingService |
ClientProtos.ClientService.newReflectiveBlockingService(ClientProtos.ClientService.BlockingInterface impl) |
Modifier and Type | Class and Description |
---|---|
class |
RSRpcServices
Implements the regionserver RPC services.
|