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 | |
org.apache.hadoop.hbase.replication.regionserver |
Modifier and Type | Method and Description |
---|---|
AdminProtos.AdminService.BlockingInterface |
DistributedHBaseCluster.getAdminProtocol(ServerName serverName) |
abstract AdminProtos.AdminService.BlockingInterface |
HBaseCluster.getAdminProtocol(ServerName serverName)
Returns an AdminProtocol interface to the regionserver
|
AdminProtos.AdminService.BlockingInterface |
MiniHBaseCluster.getAdminProtocol(ServerName serverName) |
Modifier and Type | Field and Description |
---|---|
protected AdminProtos.AdminService.BlockingInterface |
RegionAdminServiceCallable.stub |
Modifier and Type | Method and Description |
---|---|
AdminProtos.AdminService.BlockingInterface |
ClusterConnection.getAdmin(ServerName serverName)
Establishes a connection to the region server at the specified address.
|
AdminProtos.AdminService.BlockingInterface |
HConnection.getAdmin(ServerName serverName)
Deprecated.
internal method, do not use thru HConnection
|
AdminProtos.AdminService.BlockingInterface |
HConnection.getAdmin(ServerName serverName,
boolean getMaster)
Deprecated.
You can pass master flag but nothing special is done.
|
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). |
protected void |
RegionAdminServiceCallable.setStub(AdminProtos.AdminService.BlockingInterface stub) |
Modifier and Type | Class and Description |
---|---|
class |
MasterRpcServices
Implements the master RPC services.
|
Modifier and Type | Method and Description |
---|---|
static void |
ProtobufUtil.closeRegion(RpcController controller,
AdminProtos.AdminService.BlockingInterface admin,
ServerName server,
byte[] regionName,
boolean transitionInZK)
A helper to close a region given a region name
using admin protocol.
|
static boolean |
ProtobufUtil.closeRegion(RpcController controller,
AdminProtos.AdminService.BlockingInterface admin,
ServerName server,
byte[] regionName,
int versionOfClosingNode,
ServerName destinationServer,
boolean transitionInZK)
A helper to close a region given a region name
using admin protocol.
|
static java.util.List<HRegionInfo> |
ProtobufUtil.getOnlineRegions(AdminProtos.AdminService.BlockingInterface admin)
A helper to get the all the online regions on a region
server using admin protocol.
|
static java.util.List<HRegionInfo> |
ProtobufUtil.getOnlineRegions(RpcController controller,
AdminProtos.AdminService.BlockingInterface admin)
A helper to get the all the online regions on a region
server using admin protocol.
|
static HRegionInfo |
ProtobufUtil.getRegionInfo(RpcController controller,
AdminProtos.AdminService.BlockingInterface admin,
byte[] regionName)
A helper to retrieve region info given a region name
using admin protocol.
|
static AdminProtos.ServerInfo |
ProtobufUtil.getServerInfo(RpcController controller,
AdminProtos.AdminService.BlockingInterface admin)
A helper to get the info of a region server using admin protocol.
|
static java.util.List<java.lang.String> |
ProtobufUtil.getStoreFiles(AdminProtos.AdminService.BlockingInterface admin,
byte[] regionName,
byte[] family)
A helper to get the list of files of a column family
on a given region using admin protocol.
|
static java.util.List<java.lang.String> |
ProtobufUtil.getStoreFiles(RpcController controller,
AdminProtos.AdminService.BlockingInterface admin,
byte[] regionName,
byte[] family)
A helper to get the list of files of a column family
on a given region using admin protocol.
|
static void |
ProtobufUtil.mergeRegions(RpcController controller,
AdminProtos.AdminService.BlockingInterface admin,
HRegionInfo region_a,
HRegionInfo region_b,
boolean forcible)
A helper to merge regions using admin protocol.
|
static void |
ProtobufUtil.openRegion(RpcController controller,
AdminProtos.AdminService.BlockingInterface admin,
ServerName server,
HRegionInfo region)
A helper to open a region using admin protocol.
|
static void |
ReplicationProtbufUtil.replicateWALEntry(AdminProtos.AdminService.BlockingInterface admin,
WAL.Entry[] entries,
java.lang.String replicationClusterId,
Path sourceBaseNamespaceDir,
Path sourceHFileArchiveDir)
A helper to replicate a list of WAL entries using admin protocol.
|
static void |
ProtobufUtil.split(RpcController controller,
AdminProtos.AdminService.BlockingInterface admin,
HRegionInfo hri,
byte[] splitPoint)
A helper to split a region using admin protocol.
|
static void |
ProtobufUtil.warmupRegion(RpcController controller,
AdminProtos.AdminService.BlockingInterface admin,
HRegionInfo regionInfo)
A helper to warmup a region given a region name
using admin protocol
|
Modifier and Type | Method and Description |
---|---|
static AdminProtos.AdminService.BlockingInterface |
AdminProtos.AdminService.newBlockingStub(com.google.protobuf.BlockingRpcChannel channel) |
Modifier and Type | Method and Description |
---|---|
static com.google.protobuf.BlockingService |
AdminProtos.AdminService.newReflectiveBlockingService(AdminProtos.AdminService.BlockingInterface impl) |
Modifier and Type | Class and Description |
---|---|
class |
RSRpcServices
Implements the regionserver RPC services.
|
Modifier and Type | Method and Description |
---|---|
AdminProtos.AdminService.BlockingInterface |
ReplicationSinkManager.SinkPeer.getRegionServer() |
Constructor and Description |
---|
SinkPeer(ServerName serverName,
AdminProtos.AdminService.BlockingInterface regionServer) |