java连接hbase
package com.weshare.bigdata;
创新互联建站专注为客户提供全方位的互联网综合服务,包含不限于成都做网站、网站制作、成都外贸网站建设、乌尔禾网络推广、小程序设计、乌尔禾网络营销、乌尔禾企业策划、乌尔禾品牌公关、搜索引擎seo、人物专访、企业宣传片、企业代运营等,从售前售中售后,我们都将竭诚为您服务,您的肯定,是我们最大的嘉奖;创新互联建站为所有大学生创业者提供乌尔禾建站搭建服务,24小时服务热线:028-86922220,官方网址:www.cdcxhl.com
import org.apache.hadoop.hbase.Cell;
import org.apache.hadoop.hbase.HBaseConfiguration;
import org.apache.hadoop.hbase.TableName;
import org.apache.hadoop.hbase.client.*;
import org.apache.hadoop.hbase.util.Bytes;
public class hbaseLink {
static org.apache.hadoop.conf.Configuration configuration=null;
private org.apache.hadoop.hbase.client.Connection connection=null;
private Table table=null;
public void init() throws Exception{
configuration=HBaseConfiguration.create();
configuration.set("hbase.zookeeper.quorum", "服务器地址");
configuration.set("hbase.zookeeper.property.clientPort", "服务器端口");// zookeeper端口
connection=ConnectionFactory.createConnection(configuration);
// try {
// table = connection.getTable(TableName.valueOf("hbase表名"));
// ResultScanner rs = table.getScanner(new Scan());
// int num=0;
// for (Result r : rs) {
// Byte b= r.getRow(scan);
// System.out.println("获得到rowkey:" + new String(r.getRow()));
// num++;
//
// }System.out.print(num);
// }catch(Exception e){
// e.printStackTrace();
// }
}
public void queryall(String tableName) throws Exception{
table = connection.getTable(TableName.valueOf(tableName));
ResultScanner rs = table.getScanner(new Scan());
int num=0;
for (Result r : rs) {
//System.out.println("获得到rowkey:" + new String(r.getRow()));
num++;
}
System.out.print(num);
}
public void checkColName(String tableName,String rowkey,String exceptedColName) throws Exception{
table = connection.getTable(TableName.valueOf(tableName));//建立hbase表链接
Get scan = new Get(rowkey.getBytes());//获取rokey,将其转义成byte字节
Result r=table.get(scan);//使用转义的rowkey查询表,将其查询结果返回给Result
System.out.println("1");
if(r.rawCells().equals("")||r.rawCells()==null||r.rawCells().length==0){
System.out.println("3");
}
for (Cell keyValue : r.rawCells()) {
System.out.println("2");
String colName = Bytes.toString(keyValue.getQualifierArray(),keyValue.getQualifierOffset(),keyValue.getQualifierLength());
if(!colName.equals(exceptedColName)){
System.out.println("校验成功,不存在colName:"+exceptedColName+",实际colName:" + colName);
}else if(colName.isEmpty()){
System.out.println("校验成功,查询无colName");
}else{
System.out.println("校验失败");
}
System.out.println("12:"+keyValue.getFamilyLength());
}
// Get coln=scan.addFamily(rowkey.getBytes());
// NavigableMap nm=scan.getFamilyMap(rowkey.getBytes());
// System.out.println(coln.toString());
}
public static void main(String[] args) throws Exception{
hbaseLink hl=new hbaseLink();
hl.init();
hl.queryall("tablename");
// hl.checkColName("table","rowkey","column");
}
}
当前题目:java连接hbase
URL网址:http://myzitong.com/article/iigcig.html