hbase访问方式之java api

Hbase的访问方式

1、Native Java API：最常规和高效的访问方式；

2、Hbase Shell：Hbase的命令行工具，最简单的接口，适合Hbase管理使用；

3、Thrift Gateway：利用Thrift序列化技术，支持C++，PHP，Python等多种语言，适合其他异构系统在线访问Hbase表数据；

4、REST Gateway：支持REST 风格的Http API访问Hbase, 解除了语言限制；

5、MapReduce：直接使用MapReduce作业处理Hbase数据；

6、使用Pig/hive处理Hbase数据。

常用Java API的用法：

1、加载配置

Configuration config = HbaseConfiguration.create();  
//可以自定义配置，也可以从自定义配置文件中读取 
 

2、表的创建、表信息修改、表删除

HbaseAdmin admin = new HbaseAdmin(config); 
//创建表 
HTableDescriptor htd = new HTableDescriptor(tableName); 
htd.addFamily(new HColumnDescriptor("cf1")); 
htd.addFamily(new HColumnDescriptor("cf2")); 
admin.createTable(htd); 
//修改表信息 
admin.disableTable(tableName); 
// modifying existing ColumnFamily 
admin.modifyColumn(tableName, new HColumnDescriptor("cf1"));  
admin.enableTable(tableName);  
//删除表 
admin.disableTable(Bytes.toBytes(tableName)); 
admin.deleteTable(Bytes.toBytes(tableName)); 

3、添加记录

 
HTable table = new HTable(config, tableName); 
 
 
 
 
Put put1 = new Put(Bytes.toBytes(rowKey)); 
if (ts == 0) { 
  put1.add(Bytes.toBytes(family), Bytes.toBytes(qualifier), Bytes.toBytes(value)); 
} else { 
    //自定义版本时，从自定义的版本号，类型为long 
  put1.add(Bytes.toBytes(family), Bytes.toBytes(qualifier), ts,Bytes.toBytes(value)); 
} 
table.put(put1); 
//table.flushCommits(); 

4、查询，根据Rowkey查询

Get get1 = new Get(Bytes.toBytes(rowKey)); 
Result result = table.get(get1); 
System.out.println("get result:" + Bytes.toString(result.getValue(Bytes.toBytes(family), Bytes.toBytes(qualifier)))); 
Result[] result = table.get(List);//查询指定Rowkey的多条记录 

5、查询，指定条件和rowkey区间查询

Scan scan = new Scan(); 
//默认缓存大小为1，设置成一个合理的值，可以减少scan过程中next()的时间开销，代价是客户端的内存 
scan.setCaching(500); 
scan.setCacheBlocks(false); 
//根据startRowKey、endRowKey查询 
//Scan scan = new Scan(Bytes.toBytes("startRowKey"), Bytes.toBytes("endRowKey")); 
//rowKey之外的过滤条件，在List中可以add; 
 
ResultScanner scanner = table.getScanner(scan); 
System.out.println("scan result list:"); 
for (Result result : scanner) { 
  System.out.println(Bytes.toString(result.getRow())); 
  System.out.println(Bytes.toString(result.getValue(Bytes.toBytes("data"), Bytes.toBytes("data1")))); 
  System.out.println(Bytes.toString(result.getValue(Bytes.toBytes("data"), Bytes.toBytes("data2")))); 
} 
scanner.close(); 

总结

以上所述是小编给大家介绍的hbase访问方式之java api，希望对大家有所帮助，如果大家有任何疑问请给我留言，小编会及时回复大家的。在此也非常感谢大家对考高分网网站的支持！