hbase访问方式之java api
Hbase的访问方式
1、NativeJavaAPI：最常规和高效的访问方式；
2、HBaseShell：HBase的命令行工具，最简单的接口，适合HBase管理使用；
3、ThriftGateway：利用Thrift序列化技术，支持C++，PHP，Python等多种语言，适合其他异构系统在线访问HBase表数据；
4、RESTGateway：支持REST风格的HttpAPI访问HBase,解除了语言限制；
5、MapReduce：直接使用MapReduce作业处理Hbase数据；
6、使用Pig/hive处理Hbase数据。
常用Java API的用法：
1、加载配置
Configurationconfig=HBaseConfiguration.create();
//可以自定义配置，也可以从自定义配置文件中读取
/*config.set("hbase.zookeeper.property.clientPort","4181");
config.set("hbase.zookeeper.quorum","hadoop.datanode5.com,hadoop.datanode2.com,hadoop.datanode3.com");
config.set("hbase.master","hadoop.datanode3.com\\:600000");*/
2、表的创建、表信息修改、表删除
HBaseAdminadmin=newHBaseAdmin(config);
//创建表
HTableDescriptorhtd=newHTableDescriptor(tableName);
htd.addFamily(newHColumnDescriptor("cf1"));
htd.addFamily(newHColumnDescriptor("cf2"));
admin.createTable(htd);
//修改表信息
admin.disableTable(tableName);
//modifyingexistingColumnFamily
admin.modifyColumn(tableName,newHColumnDescriptor("cf1"));
admin.enableTable(tableName);
//删除表
admin.disableTable(Bytes.toBytes(tableName));
admin.deleteTable(Bytes.toBytes(tableName));
3、添加记录
/**在多次使用时，建议用HTablePool
HTabletable=newHTable(config,tableName);
=>
HTablePoolpool=newHTablePool(config,1000);
HTableInterfacetable=pool.getTable(tableName);*/
HTabletable=newHTable(config,tableName);
/**
*在插入操作时，默认不适用任何缓存
*可自定义使用缓存，以及缓存大小
*每个任务最后需要手工调用flushCommits();
*/
/*table.setAutoFlush(false);
table.setWriteBufferSize(1024);*/
Putput1=newPut(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查询
Getget1=newGet(Bytes.toBytes(rowKey));
Resultresult=table.get(get1);
System.out.println("getresult:"+Bytes.toString(result.getValue(Bytes.toBytes(family),Bytes.toBytes(qualifier))));
Result[]result=table.get(List);//查询指定Rowkey的多条记录
5、查询，指定条件和rowkey区间查询
Scanscan=newScan();
//默认缓存大小为1，设置成一个合理的值，可以减少scan过程中next()的时间开销，代价是客户端的内存
scan.setCaching(500);
scan.setCacheBlocks(false);
//根据startRowKey、endRowKey查询
//Scanscan=newScan(Bytes.toBytes("startRowKey"),Bytes.toBytes("endRowKey"));
//rowKey之外的过滤条件，在List中可以add;
/**Listfilters=newArrayList();
Filterfilter=newSingleColumnValueFilter("familyName".getBytes(),
"qualifierName".getBytes(),
CompareOp.EQUAL,
Bytes.toBytes("value"));
filters.add(filter);
scan.setFilter(newFilterList(filters));*/
ResultScannerscanner=table.getScanner(scan);
System.out.println("scanresultlist:");
for(Resultresult: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访问方式之javaapi，希望对大家有所帮助，如果大家有任何疑问请给我留言，小编会及时回复大家的。在此也非常感谢大家对毛票票网站的支持！