Java 操作 HBase 教程

Posted Java3y

tags:

篇首语：本文由小常识网(cha138.com)小编为大家整理，主要介绍了Java 操作 HBase 教程相关的知识，希望对你有一定的参考价值。


本文公众号来源：美码师
作者：美码师
本文已收录至我的 GitHub

一、简介

在上一篇文章 中，我们已经介绍了 HBase 的一些基本概念，以及如何安装使用的方法。那么，作为一名 Javaer，自然是希望用 Java 的方式来与 HBase 进行对话了。所幸的是，HBase 本身就是用 Java 编写的，天生自带了 Java 原生API。我们可以通过 hbase-client 来实现 HBase 数据库的操作。所以，这次主要介绍该组件的基本用法。

在使用 hbase-client 之前，有几个要点需要注意：

  • 客户端需要能访问 Zoopkeeper，再获得 HMaster、RegionServer 实例进行操作

  • 客户端需运行在HBase/Hadoop 集群内，HBase会使用 hostname 来定位节点，因此要求客户端能访问到对应的主机名(或子域名) 如果是远程客户端则需要配置本地的hosts文件。

下面这个图，有助于理解 Client 与 HBase 集群的交互架构：

Java 操作 HBase 教程

下面开始介绍 client 的使用。


二、hbase-client 引入

在 Maven 的 pom.xml 中添加依赖：

 
   
   
 
    
  
    
    
  
  1. <dependency>
    2. 
  
    
    
  
  2.  <groupId>org.apache.hbase</groupId>
    3. 
  
    
    
  
  3.  <artifactId>hbase-client</artifactId>
    4. 
  
    
    
  
  4.  <version>2.1.5</version>
    5. 
  
    
    
  
  5.  <exclusions>
    6. 
  
    
    
  
  6.  <exclusion>
    7. 
  
    
    
  
  7.  <artifactId>slf4j-api</artifactId>
    8. 
  
    
    
  
  8.  <groupId>org.slf4j</groupId>
    9. 
  
    
    
  
  9.  </exclusion>
    10. 
  
    
    
  
  10.  <exclusion>
    11. 
  
    
    
  
  11.  <artifactId>slf4j-log4j12</artifactId>
    12. 
  
    
    
  
  12.  <groupId>org.slf4j</groupId>
    13. 
  
    
    
  
  13.  </exclusion>
    14. 
  
    
    
  
  14.  </exclusions>
    15. 
  
    
    
  
  15. </dependency>
    16. 
  
    
    
  
  16. <dependency>
    17. 
  
    
    
  
  17.  <groupId>org.apache.hbase</groupId>
    18. 
  
    
    
  
  18.  <artifactId>hbase</artifactId>
    19. 
  
    
    
  
  19.  <version>2.1.5</version>
    20. 
  
    
    
  
  20. </dependency>
    21.

这里需要注意的是，客户端版本和 HBase 版本需要保持一致，否则可能会遇到不兼容的问题。


三、连接操作

示例代码：

 
   
   
 
    
  
    
    
  
  1. /**
    2. 
  
    
    
  
  2.  * 建立连接
    3. 
  
    
    
  
  3.  *
    4. 
  
    
    
  
  4.  * @return
    5. 
  
    
    
  
  5.  */
    6. 
  
    
    
  
  6. public static Connection getConnection() {
    7. 
  
    
    
  
  7.  try {
    8. 
  
    
    
  
  8.  //获取配置
    9. 
  
    
    
  
  9.  Configuration configuration = getConfiguration();
    10. 
  
    
    
  
  10.  //检查配置
    11. 
  
    
    
  
  11.  HBaseAdmin.checkHBaseAvailable(configuration);
    12. 
  
    
    
  
  12.  return ConnectionFactory.createConnection(configuration);
    13. 
  
    
    
  
  13.  } catch (IOException | ServiceException e) {
    14. 
  
    
    
  
  14.  throw new RuntimeException(e);
    15. 
  
    
    
  
  15.  }
    16. 
  
    
    
  
  16. }
    17. 
  
    
    
  

    18. 
  
    
    
  
  18. /**
    19. 
  
    
    
  
  19.  * 获取配置
    20. 
  
    
    
  
  20.  *
    21. 
  
    
    
  
  21.  * @return
    22. 
  
    
    
  
  22.  */
    23. 
  
    
    
  
  23. private static Configuration getConfiguration() {
    24. 
  
    
    
  
  24.  try {
    25. 
  
    
    
  
  25.  Properties props = PropertiesLoaderUtils
    26. 
  
    
    
  
  26.  .loadAllProperties("hbase.properties");
    27. 
  
    
    
  
  27.  String clientPort = props
    28. 
  
    
    
  
  28.  .getProperty("hbase.zookeeper.property.clientPort");
    29. 
  
    
    
  
  29.  String quorum = props
    30. 
  
    
    
  
  30.  .getProperty("hbase.zookeeper.quorum");
    31. 
  
    
    
  

    32. 
  
    
    
  
  32.  logger.info("connect to zookeeper {}:{}", quorum, clientPort);
    33. 
  
    
    
  

    34. 
  
    
    
  
  34.  Configuration config = HBaseConfiguration.create();
    35. 
  
    
    
  
  35.  config.set("hbase.zookeeper.property.clientPort", clientPort);
    36. 
  
    
    
  
  36.  config.set("hbase.zookeeper.quorum", quorum);
    37. 
  
    
    
  
  37.  return config;
    38. 
  
    
    
  
  38.  } catch (IOException e) {
    39. 
  
    
    
  
  39.  throw new RuntimeException(e);
    40. 
  
    
    
  
  40.  }
    41. 
  
    
    
  
  41. }
    42.

四、表操作

增删改查方法封装如下：

 
   
   
 
    
  
    
    
  
  1. /**
    2. 
  
    
    
  
  2.  * 创建表
    3. 
  
    
    
  
  3.  * @param connection
    4. 
  
    
    
  
  4.  * @param tableName
    5. 
  
    
    
  
  5.  * @param columnFamilies
    6. 
  
    
    
  
  6.  * @throws IOException
    7. 
  
    
    
  
  7.  */
    8. 
  
    
    
  
  8. public static void createTable(Connection connection, TableName tableName, String... columnFamilies) throws IOException {
    9. 
  
    
    
  
  9.  Admin admin = null;
    10. 
  
    
    
  
  10.  try {
    11. 
  
    
    
  
  11.  admin = connection.getAdmin();
    12. 
  
    
    
  
  12.  if (admin.tableExists(tableName)) {
    13. 
  
    
    
  
  13.  logger.warn("table:{} exists!", tableName.getName());
    14. 
  
    
    
  
  14.  } else {
    15. 
  
    
    
  
  15.  TableDescriptorBuilder builder = TableDescriptorBuilder.newBuilder(tableName);
    16. 
  
    
    
  
  16.  for (String columnFamily : columnFamilies) {
    17. 
  
    
    
  
  17.  builder.setColumnFamily(ColumnFamilyDescriptorBuilder.of(columnFamily));
    18. 
  
    
    
  
  18.  }
    19. 
  
    
    
  
  19.  admin.createTable(builder.build());
    20. 
  
    
    
  
  20.  logger.info("create table:{} success!", tableName.getName());
    21. 
  
    
    
  
  21.  }
    22. 
  
    
    
  
  22.  } finally {
    23. 
  
    
    
  
  23.  if (admin != null) {
    24. 
  
    
    
  
  24.  admin.close();
    25. 
  
    
    
  
  25.  }
    26. 
  
    
    
  
  26.  }
    27. 
  
    
    
  
  27. }
    28. 
  
    
    
  

    29. 
  
    
    
  

    30. 
  
    
    
  
  30. /**
    31. 
  
    
    
  
  31.  * 插入数据
    32. 
  
    
    
  
  32.  *
    33. 
  
    
    
  
  33.  * @param connection
    34. 
  
    
    
  
  34.  * @param tableName
    35. 
  
    
    
  
  35.  * @param rowKey
    36. 
  
    
    
  
  36.  * @param columnFamily
    37. 
  
    
    
  
  37.  * @param column
    38. 
  
    
    
  
  38.  * @param data
    39. 
  
    
    
  
  39.  * @throws IOException
    40. 
  
    
    
  
  40.  */
    41. 
  
    
    
  
  41. public static void put(Connection connection, TableName tableName,
    42. 
  
    
    
  
  42.  String rowKey, String columnFamily, String column, String data) throws IOException {
    43. 
  
    
    
  

    44. 
  
    
    
  
  44.  Table table = null;
    45. 
  
    
    
  
  45.  try {
    46. 
  
    
    
  
  46.  table = connection.getTable(tableName);
    47. 
  
    
    
  
  47.  Put put = new Put(Bytes.toBytes(rowKey));
    48. 
  
    
    
  
  48.  put.addColumn(Bytes.toBytes(columnFamily), Bytes.toBytes(column), Bytes.toBytes(data));
    49. 
  
    
    
  
  49.  table.put(put);
    50. 
  
    
    
  
  50.  } finally {
    51. 
  
    
    
  
  51.  if (table != null) {
    52. 
  
    
    
  
  52.  table.close();
    53. 
  
    
    
  
  53.  }
    54. 
  
    
    
  
  54.  }
    55. 
  
    
    
  
  55. }
    56. 
  
    
    
  

    57. 
  
    
    
  
  57. /**
    58. 
  
    
    
  
  58.  * 根据row key、column 读取
    59. 
  
    
    
  
  59.  *
    60. 
  
    
    
  
  60.  * @param connection
    61. 
  
    
    
  
  61.  * @param tableName
    62. 
  
    
    
  
  62.  * @param rowKey
    63. 
  
    
    
  
  63.  * @param columnFamily
    64. 
  
    
    
  
  64.  * @param column
    65. 
  
    
    
  
  65.  * @throws IOException
    66. 
  
    
    
  
  66.  */
    67. 
  
    
    
  
  67. public static String getCell(Connection connection, TableName tableName, String rowKey, String columnFamily, String column) throws IOException {
    68. 
  
    
    
  
  68.  Table table = null;
    69. 
  
    
    
  
  69.  try {
    70. 
  
    
    
  
  70.  table = connection.getTable(tableName);
    71. 
  
    
    
  
  71.  Get get = new Get(Bytes.toBytes(rowKey));
    72. 
  
    
    
  
  72.  get.addColumn(Bytes.toBytes(columnFamily), Bytes.toBytes(column));
    73. 
  
    
    
  

    74. 
  
    
    
  
  74.  Result result = table.get(get);
    75. 
  
    
    
  
  75.  List<Cell> cells = result.listCells();
    76. 
  
    
    
  

    77. 
  
    
    
  
  77.  if (CollectionUtils.isEmpty(cells)) {
    78. 
  
    
    
  
  78.  return null;
    79. 
  
    
    
  
  79.  }
    80. 
  
    
    
  
  80.  String value = new String(CellUtil.cloneValue(cells.get(0)), "UTF-8");
    81. 
  
    
    
  
  81.  return value;
    82. 
  
    
    
  
  82.  } finally {
    83. 
  
    
    
  
  83.  if (table != null) {
    84. 
  
    
    
  
  84.  table.close();
    85. 
  
    
    
  
  85.  }
    86. 
  
    
    
  
  86.  }
    87. 
  
    
    
  
  87. }
    88. 
  
    
    
  

    89. 
  
    
    
  
  89. /**
    90. 
  
    
    
  
  90.  * 根据rowkey 获取一行
    91. 
  
    
    
  
  91.  *
    92. 
  
    
    
  
  92.  * @param connection
    93. 
  
    
    
  
  93.  * @param tableName
    94. 
  
    
    
  
  94.  * @param rowKey
    95. 
  
    
    
  
  95.  * @return
    96. 
  
    
    
  
  96.  * @throws IOException
    97. 
  
    
    
  
  97.  */
    98. 
  
    
    
  
  98. public static Map<String, String> getRow(Connection connection, TableName tableName, String rowKey) throws IOException {
    99. 
  
    
    
  
  99.  Table table = null;
    100. 
  
    
    
  
  100.  try {
    101. 
  
    
    
  
  101.  table = connection.getTable(tableName);
    102. 
  
    
    
  
  102.  Get get = new Get(Bytes.toBytes(rowKey));
    103. 
  
    
    
  

    104. 
  
    
    
  
  104.  Result result = table.get(get);
    105. 
  
    
    
  
  105.  List<Cell> cells = result.listCells();
    106. 
  
    
    
  

    107. 
  
    
    
  
  107.  if (CollectionUtils.isEmpty(cells)) {
    108. 
  
    
    
  
  108.  return Collections.emptyMap();
    109. 
  
    
    
  
  109.  }
    110. 
  
    
    
  
  110.  Map<String, String> objectMap = new HashMap<>();
    111. 
  
    
    
  
  111.  for (Cell cell : cells) {
    112. 
  
    
    
  
  112.  String qualifier = new String(CellUtil.cloneQualifier(cell));
    113. 
  
    
    
  
  113.  String value = new String(CellUtil.cloneValue(cell), "UTF-8");
    114. 
  
    
    
  
  114.  objectMap.put(qualifier, value);
    115. 
  
    
    
  
  115.  }
    116. 
  
    
    
  
  116.  return objectMap;
    117. 
  
    
    
  
  117.  } finally {
    118. 
  
    
    
  
  118.  if (table != null) {
    119. 
  
    
    
  
  119.  table.close();
    120. 
  
    
    
  
  120.  }
    121. 
  
    
    
  
  121.  }
    122. 
  
    
    
  
  122. }
    123. 
  
    
    
  

    124. 
  
    
    
  
  124. /**
    125. 
  
    
    
  
  125.  * 扫描权标的内容
    126. 
  
    
    
  
  126.  *
    127. 
  
    
    
  
  127.  * @param connection
    128. 
  
    
    
  
  128.  * @param tableName
    129. 
  
    
    
  
  129.  * @param rowkeyStart
    130. 
  
    
    
  
  130.  * @param rowkeyEnd
    131. 
  
    
    
  
  131.  * @throws IOException
    132. 
  
    
    
  
  132.  */
    133. 
  
    
    
  
  133. public static List<Map<String, String>> scan(Connection connection, TableName tableName, String rowkeyStart, String rowkeyEnd) throws IOException {
    134. 
  
    
    
  
  134.  Table table = null;
    135. 
  
    
    
  
  135.  try {
    136. 
  
    
    
  
  136.  table = connection.getTable(tableName);
    137. 
  
    
    
  
  137.  ResultScanner rs = null;
    138. 
  
    
    
  
  138.  try {
    139. 
  
    
    
  
  139.  Scan scan = new Scan();
    140. 
  
    
    
  
  140.  if (!StringUtils.isEmpty(rowkeyStart)) {
    141. 
  
    
    
  
  141.  scan.withStartRow(Bytes.toBytes(rowkeyStart));
    142. 
  
    
    
  
  142.  }
    143. 
  
    
    
  
  143.  if (!StringUtils.isEmpty(rowkeyEnd)) {
    144. 
  
    
    
  
  144.  scan.withStopRow(Bytes.toBytes(rowkeyEnd));
    145. 
  
    
    
  
  145.  }
    146. 
  
    
    
  
  146.  rs = table.getScanner(scan);
    147. 
  
    
    
  

    148. 
  
    
    
  
  148.  List<Map<String, String>> dataList = new ArrayList<>();
    149. 
  
    
    
  
  149.  for (Result r : rs) {
    150. 
  
    
    
  
  150.  Map<String, String> objectMap = new HashMap<>();
    151. 
  
    
    
  
  151.  for (Cell cell : r.listCells()) {
    152. 
  
    
    
  
  152.  String qualifier = new String(CellUtil.cloneQualifier(cell));
    153. 
  
    
    
  
  153.  String value = new String(CellUtil.cloneValue(cell), "UTF-8");
    154. 
  
    
    
  
  154.  objectMap.put(qualifier, value);
    155. 
  
    
    
  
  155.  }
    156. 
  
    
    
  
  156.  dataList.add(objectMap);
    157. 
  
    
    
  
  157.  }
    158. 
  
    
    
  
  158.  return dataList;
    159. 
  
    
    
  
  159.  } finally {
    160. 
  
    
    
  
  160.  if (rs != null) {
    161. 
  
    
    
  
  161.  rs.close();
    162. 
  
    
    
  
  162.  }
    163. 
  
    
    
  
  163.  }
    164. 
  
    
    
  
  164.  } finally {
    165. 
  
    
    
  
  165.  if (table != null) {
    166. 
  
    
    
  
  166.  table.close();
    167. 
  
    
    
  
  167.  }
    168. 
  
    
    
  
  168.  }
    169. 
  
    
    
  
  169. }
    170. 
  
    
    
  

    171. 
  
    
    
  
  171. /**
    172. 
  
    
    
  
  172.  * 删除表
    173. 
  
    
    
  
  173.  *
    174. 
  
    
    
  
  174.  * @param connection
    175. 
  
    
    
  
  175.  * @param tableName
    176. 
  
    
    
  
  176.  * @throws IOException
    177. 
  
    
    
  
  177.  */
    178. 
  
    
    
  
  178. public static void deleteTable(Connection connection, TableName tableName) throws IOException {
    179. 
  
    
    
  
  179.  Admin admin = null;
    180. 
  
    
    
  
  180.  try {
    181. 
  
    
    
  
  181.  admin = connection.getAdmin();
    182. 
  
    
    
  
  182.  if (admin.tableExists(tableName)) {
    183. 
  
    
    
  
  183.  //现执行disable
    184. 
  
    
    
  
  184.  admin.disableTable(tableName);
    185. 
  
    
    
  
  185.  admin.deleteTable(tableName);
    186. 
  
    
    
  
  186.  }
    187. 
  
    
    
  
  187.  } finally {
    188. 
  
    
    
  
  188.  if (admin != null) {
    189. 
  
    
    
  
  189.  admin.close();
    190. 
  
    
    
  
  190.  }
    191. 
  
    
    
  
  191.  }
    192. 
  
    
    
  
  192. }
    193.


五、运行测试

最后，我们仍然以上一篇文章中的设备数据作为例子：

  1. 建立 DeviceState 表；

  2. 定义 name/state 两个列簇；

  3. 写入列数据；

  4. 读取列、行，范围读取；

  5. 删除操作

最终实现的代码如下：

 
   
   
 
    
  
    
    
  
  1. private static final Logger logger = LoggerFactory.getLogger(HBaseTest.class);
    2. 
  
    
    
  

    3. 
  
    
    
  
  3. public static void main(String[] args) {
    4. 
  
    
    
  

    5. 
  
    
    
  
  5.  Connection connection = null;
    6. 
  
    
    
  
  6.  try {
    7. 
  
    
    
  
  7.  connection = getConnection();
    8. 
  
    
    
  
  8.  TableName tableName = TableName.valueOf("DeviceState");
    9. 
  
    
    
  

    10. 
  
    
    
  
  10.  //创建DeviceState表
    11. 
  
    
    
  
  11.  createTable(connection, tableName, "name", "state");
    12. 
  
    
    
  

    13. 
  
    
    
  
  13.  logger.info("创建表 {}", tableName.getNameAsString());
    14. 
  
    
    
  

    15. 
  
    
    
  
  15.  //写入数据
    16. 
  
    
    
  
  16.  put(connection, tableName, "row1", "name", "c1", "空调");
    17. 
  
    
    
  
  17.  put(connection, tableName, "row1", "state", "c2", "打开");
    18. 
  
    
    
  
  18.  put(connection, tableName, "row2", "name", "c1", "电视机");
    19. 
  
    
    
  
  19.  put(connection, tableName, "row2", "state", "c2", "关闭");
    20. 
  
    
    
  

    21. 
  
    
    
  
  21.  logger.info("写入数据.");
    22. 
  
    
    
  

    23. 
  
    
    
  
  23.  String value = getCell(connection, tableName, "row1", "state", "c2");
    24. 
  
    
    
  
  24.  logger.info("读取单元格-row1.state:{}", value);
    25. 
  
    
    
  

    26. 
  
    
    
  
  26.  Map<String, String> row = getRow(connection, tableName, "row2");
    27. 
  
    
    
  
  27.  logger.info("读取单元格-row2:{}", JsonUtil.toJson(row));
    28. 
  
    
    
  

    29. 
  
    
    
  
  29.  List<Map<String, String>> dataList = scan(connection, tableName, null, null);
    30. 
  
    
    
  
  30.  logger.info("扫描表结果-:
{}", JsonUtil.toPrettyJson(dataList));
    31. 
  
    
    
  

    32. 
  
    
    
  
  32.  //删除DeviceState表
    33. 
  
    
    
  
  33.  deleteTable(connection, tableName);
    34. 
  
    
    
  
  34.  logger.info("删除表 {}", tableName.getNameAsString());
    35. 
  
    
    
  

    36. 
  
    
    
  
  36.  logger.info("操作完成.");
    37. 
  
    
    
  
  37.  } catch (Exception e) {
    38. 
  
    
    
  
  38.  logger.error("操作出错", e);
    39. 
  
    
    
  
  39.  } finally {
    40. 
  
    
    
  
  40.  if (connection != null) {
    41. 
  
    
    
  
  41.  try {
    42. 
  
    
    
  
  42.  connection.close();
    43. 
  
    
    
  
  43.  } catch (IOException e) {
    44. 
  
    
    
  
  44.  logger.error("error occurs", e);
    45. 
  
    
    
  
  45.  }
    46. 
  
    
    
  
  46.  }
    47. 
  
    
    
  
  47.  }
    48. 
  
    
    
  

    49. 
  
    
    
  
  49. }
    50.

执行代码，控制台输出如下：

 
   
   
 
    
  
    
    
  
  1. INFO -createTable(HBaseTest.java:89) - create table:[68, 101, 118, 105, 99, 101, 83, 116, 97, 116, 101] success!
    2. 
  
    
    
  
  2. INFO -main(HBaseTest.java:32) - 创建表 DeviceState
    3. 
  
    
    
  
  3. INFO -main(HBaseTest.java:40) - 写入数据.
    4. 
  
    
    
  
  4. INFO -main(HBaseTest.java:43) - 读取单元格-row1.state:打开
    5. 
  
    
    
  
  5. INFO -main(HBaseTest.java:46) - 读取单元格-row2:{"c1":"电视机","c2":"关闭"}
    6. 
  
    
    
  
  6. INFO -main(HBaseTest.java:49) - 扫描表结果-:
    7. 
  
    
    
  
  7. [ {
    8. 
  
    
    
  
  8. "c1": "空调",
    9. 
  
    
    
  
  9. "c2": "打开"
    10. 
  
    
    
  
  10. }, {
    11. 
  
    
    
  
  11. "c1": "电视机",
    12. 
  
    
    
  
  12. "c2": "关闭"
    13. 
  
    
    
  
  13. } ]
    14. 
  
    
    
  
  14. INFO -HBaseAdmin$9.call(HBaseAdmin.java:1380) - Started disable of DeviceState
    15. 
  
    
    
  
  15. INFO -HBaseAdmin$DisableTableFuture.postOperationResult(HBaseAdmin.java:1409) - DisabledDeviceState
    16. 
  
    
    
  
  16. INFO -HBaseAdmin$DeleteTableFuture.postOperationResult(HBaseAdmin.java:965) - DeletedDeviceState
    17. 
  
    
    
  
  17. INFO -main(HBaseTest.java:53) - 删除表 DeviceState
    18. 
  
    
    
  
  18. INFO -main(HBaseTest.java:55) - 操作完成.
    19.

此时Java Client已经完成制作。


FAQ

A. 提示报错 找不到 winutils 程序

Failed to locate the winutils binary in the hadoop binary path

原因

在Windows下依赖一个 winutils.exe 程序，该程序通过${HADOOPHOME}/bin 来查找。该报错不影响程序执行。

解决办法

需要下载hadoop-commons-master，再配置变量 HADOOPHOME

B. 提示报错，UnknownHostException，无法找到节点..
原因
客户端无法解析HMaster实例节点的主机名 
解决办法
需要编辑 C:WindowsSystem32driversetchosts 文件，添加对应的映射，如下： 
 
   
   
 
    
  
    
    
  

  1.  
   
     
    47.xx.8x.xx izwz925kr63w5jitjys6dtt 
   
    2.


参考文档

官方文档 https://hbase.apache.org/book.html#quickstart Java HBase客户端API https://www.baeldung.com/hbase



欢迎加入 交流群 学习，备注 加群
说实话在这个群，哪怕您不说话，光看聊天记录，都能学到东西Java 操作 HBase 教程


Java 操作 HBase 教程

推荐阿里云推广服务器89/年，229/3年，买来送自己，送女朋友马上过年再合适不过了，买了搭建个项目给面试官看也香，还可以熟悉技术栈，(老用户用家人账号买就好了，我用我女朋友的

以上是关于Java 操作 HBase 教程的主要内容，如果未能解决你的问题，请参考以下文章

暑期——第八周总结（Hbase命令详解）

HBase Thrift协议编程入门教程

通过Java操作HBase

HBase Shell基本操作 一万字

如何使用Java API操作Hbase

Hbase-2.0.0_02_常用操作