这篇文章主要介绍“HBase2 java Api接口举例分析”,在日常操作中,相信很多人在HBase2 java Api接口举例分析问题上存在疑惑,小编查阅了各式资料,整理出简单好用的操作方法,希望对大家解答”HBase2 java Api接口举例分析”的疑惑有所帮助!接下来,请跟着小编一起来学习吧!
公司主营业务:成都网站制作、网站设计、移动网站开发等业务。帮助企业客户真正实现互联网宣传,提高企业的竞争能力。成都创新互联是一支青春激扬、勤奋敬业、活力青春激扬、勤奋敬业、活力澎湃、和谐高效的团队。公司秉承以“开放、自由、严谨、自律”为核心的企业文化,感谢他们对我们的高要求,感谢他们从不同领域给我们带来的挑战,让我们激情的团队有机会用头脑与智慧不断的给客户带来惊喜。成都创新互联推出固镇免费做网站回馈大家。
接口介绍
拦截器
CompareOperator.LESS 匹配小宇设定值的值
CompareOperator.LESS_OR_EQUAL 匹配小宇或等于设定值的值
CompareOperator.EQUAL 匹配等于设定值的值
CompareOperator.NOT_EQUAL 匹配与设定值不相等的值
CompareOperator.GREATER_OR_EQUAL 匹配大于或等于设定值的值
CompareOperator.GREATER 匹配大于设定值的值 CompareOperator.NO_OP 排除一切值
比较器种类
RowFilter :基于行键来过滤数据;
FamilyFilterr :基于列族来过滤数据;
QualifierFilterr :基于列限定符(列名)来过滤数据;
ValueFilterr :基于单元格 (cell) 的值来过滤数据;
DependentColumnFilter :指定一个参考列来过滤其他列的过滤器,过滤的原则是基于参考列的时间戳来进行筛选 。
比较器
BinaryComparator 使用Bytes.compareTo()比较当前值与阈值
BinaryPrefixComparator 与上面类似,但是是从左端开始前缀匹配
NullComparator 不做匹配,只判断当前值是不是null
BitComparator 通过BitwiseOp类提供的按位与(AND)、或(OR)、异或(XOR)操作执行位级比较 ,只能用EQUAL和NOT_EQUAL
RegexStringComparator 根据一个正则表达式,在实例化这个比较器的时候去匹配表中的数据 ,只能用* EQUAL和NOT_EQUAL
SubStringComparator 把阈值和表中数据当做String实例,同时通过contains()操作匹配字符串,只能用EQUAL和NOT_EQUAL
专用过滤器
单列列值过滤器 (SingleColumnValueFilter)
单列列值排除器 (SingleColumnValueExcludeFilter)
行键前缀过滤器 (PrefixFilter)
列名前缀过滤器 (ColumnPrefixFilter)
分页过滤器 (PageFilter)
时间戳过滤器 (TimestampsFilter)
首次行键过滤器 (FirstKeyOnlyFilter)
包装过滤器
SkipFilter过滤器,遇到需要过滤keyvalue实例时,拓张过滤整行数据
WhileMatchFilter过滤器 遇到一个需要过滤的 KeyValue 实例时,WhileMatchFilter 则结束本次扫描,返回已经扫描到的结果
FilterList 过滤器类组合,多种类型过滤器组合。
java代码
maven导包
日志接口框架使用slf4j,这里去除commons-logging。
org.apache.hbase hbase-client 2.0.2 commons-logging commons-logging
java代码
实现对hbase库数据的增删改查,支持kerberos认证,为避免复杂参数设置,这里直接引入hadoop和hbase配置文件。
import java.io.IOException; import java.util.ArrayList; import java.util.List; import org.apache.hadoop.conf.Configuration; import org.apache.hadoop.fs.Path; import org.apache.hadoop.hbase.Cell; import org.apache.hadoop.hbase.CompareOperator; import org.apache.hadoop.hbase.HBaseConfiguration; import org.apache.hadoop.hbase.TableName; import org.apache.hadoop.hbase.client.Connection; import org.apache.hadoop.hbase.client.ConnectionFactory; import org.apache.hadoop.hbase.client.Get; import org.apache.hadoop.hbase.client.HBaseAdmin; import org.apache.hadoop.hbase.client.Result; import org.apache.hadoop.hbase.client.ResultScanner; import org.apache.hadoop.hbase.client.Scan; import org.apache.hadoop.hbase.client.Table; import org.apache.hadoop.hbase.filter.Filter; import org.apache.hadoop.hbase.filter.RowFilter; import org.apache.hadoop.hbase.filter.SubstringComparator; import org.apache.hadoop.hbase.util.Bytes; import org.apache.hadoop.security.UserGroupInformation; import org.slf4j.Logger; import org.slf4j.LoggerFactory; public final class HbaseUtil { private static Logger log= LoggerFactory.getLogger(HbaseUtil.class); private Connection connection; public HbaseUtil() throws IOException { Configuration conf = HBaseConfiguration.create(); conf.addResource(new Path(ConfigUtil.hbaseFile)); conf.addResource(new Path(ConfigUtil.coreFile)); conf.addResource(new Path(ConfigUtil.hdfsFile)); if(ConfigUtil.kerberos==1) { System.setProperty("java.security.krb5.conf", "/etc/krb5.conf"); UserGroupInformation.setConfiguration(conf); UserGroupInformation.loginUserFromKeytab(ConfigUtil.kerberosUser,ConfigUtil.kerberosFile); HBaseAdmin.available(conf); } this.connection=ConnectionFactory.createConnection(conf); } /** * 范围查询 * @param tableName 表名 * @param startRowkey 开始rowkey * @param endRowkey 结束rowkey不查询 * @return */ public ListgetData(String tableName,String startRowkey,String endRowkey){ log.info("Search Table {} ,Startrowkey:{} ,Endrowkey:{}",tableName,startRowkey,endRowkey); List dataList=new ArrayList<>(); ResultScanner resultList = null; String rowkey; String filterString=startRowkey.substring(4); try { Table tableModel=connection.getTable(TableName.valueOf(tableName)); Scan scan = new Scan(); //添加start和end scan.withStartRow(Bytes.toBytes(startRowkey)); scan.withStopRow(Bytes.toBytes(endRowkey)); scan.addColumn(Bytes.toBytes(ConfigUtil.familyName), Bytes.toBytes(ConfigUtil.cloumnName)); resultList = tableModel.getScanner(scan); if(resultList!=null) { for (Result result : resultList) { //TODO 添加rowkey规范验证 rowkey = Bytes.toString(result.getValue(Bytes.toBytes(ConfigUtil.familyName), Bytes.toBytes(ConfigUtil.cloumnName))); if(StringUtil.isNotEmpty(rowkey)) { dataList.add(rowkey); } } } tableModel.close(); } catch (Exception e) { log.error(e.toString(),e); } return dataList; } /** * 根据rowkey批量查询 * @param tableName 表名 * @param rowkeyList rowkey列表 * @return */ public List getDataList(String tableName,List rowkeyList){ log.info("Search Table {} ,rowkeyList:{} ",tableName,JsonUtil.toJson(rowkeyList)); List dataList=new ArrayList<>(); try { Table tableModel=connection.getTable(TableName.valueOf(tableName)); List getList=new ArrayList<>(); for(String rowkey:rowkeyList) { getList.add(new Get(Bytes.toBytes(rowkey))); } //查询 Result[] resultList=tableModel.get(getList); //存储数据 if(resultList!=null&&resultList.length>0) { Cell[] cellList; for(Result result:resultList) { cellList=result.rawCells(); for(Cell cell:cellList) { dataList.add(Bytes.toString(cell.getValueArray())); } } } tableModel.close(); } catch (Exception e) { log.error(e.toString(),e); } return dataList; } /** * 创建表 * @param tableName */ public boolean createTable(String tableName){ try { //判断数据库是否存在 Admin admin=this.connection.getAdmin(); NamespaceDescriptor[] namespace=admin.listNamespaceDescriptors(); int state=0; //获取命名空间 if(namespace.length>0) { for(NamespaceDescriptor name:namespace){ if(name.getName().equals(ConfigUtil.dataName)){ state=1; } } } //创建命名空间 if(state==0){ log.info("Create NameSpace {}",ConfigUtil.dataName); admin.createNamespace(NamespaceDescriptor.create(ConfigUtil.dataName).build()); } TableName table= TableName.valueOf(ConfigUtil.dataName+":"+tableName); //创建表 if(admin.tableExists(table)){ log.info("{} tables Exists!",tableName); }else{ log.info("Create Table {}",tableName); //表描述器构造器 TableDescriptorBuilder tdb =TableDescriptorBuilder.newBuilder(table); //列族描述起构造器 ColumnFamilyDescriptorBuilder cdb = ColumnFamilyDescriptorBuilder.newBuilder(Bytes.toBytes(ConfigUtil.familyName)); //存储时间 cdb.setTimeToLive(ConfigUtil.saveTime*24*60*60); //获得列描述起 ColumnFamilyDescriptor cfd = cdb.build(); //添加列族 tdb.setColumnFamily(cfd); //获得表描述器 TableDescriptor td = tdb.build(); //创建表 admin.createTable(td); log.info("{} Table Create Success!",tableName); } return true; } catch (Exception e) { log.error(e.toString(),e); } return false; } /** * 判断表是否存在 * @param tableName * @return */ public boolean getTableStatus(String tableName){ try { Admin admin=this.connection.getAdmin(); return admin.tableExists(TableName.valueOf(ConfigUtil.dataName+":"+tableName)); } catch (Exception e) { log.error(e.toString(),e); } return false; } /** * 删除表 */ public boolean delTable(String tableName){ try { TableName table=TableName.valueOf(ConfigUtil.dataName+":"+tableName); Admin admin=this.connection.getAdmin(); if(admin.tableExists(table)){ admin.disableTable(table); admin.deleteTable(table); log.info("Delete {} Success!",tableName); }else{ log.info("No Found Table:{}",tableName); } return true; } catch (Exception e) { log.error(e.toString(),e); } return false; } /** * 添加数据 * @param tableName * @param data */ public void addData(String tableName,Map data) { try { Table tableModel=connection.getTable(TableName.valueOf(ConfigUtil.dataName+":"+tableName)); List puts = new ArrayList<>(); Put put; for(Map.Entry entry:data.entrySet()) { put= new Put(Bytes.toBytes(entry.getKey())); put.addColumn(Bytes.toBytes(ConfigUtil.familyName),Bytes.toBytes(ConfigUtil.cloumnName), Bytes.toBytes(entry.getValue())); puts.add(put); } tableModel.put(puts); tableModel.close(); } catch (Exception e) { log.error(e.toString(),e); } } /** * 关闭连接 */ public void close() { try { this.connection.close(); } catch (IOException e) { log.error(e.toString(),e); } } }
到此,关于“HBase2 java Api接口举例分析”的学习就结束了,希望能够解决大家的疑惑。理论与实践的搭配能更好的帮助大家学习,快去试试吧!若想继续学习更多相关知识,请继续关注创新互联网站,小编会继续努力为大家带来更多实用的文章!
网页名称:HBase2javaApi接口举例分析
网页地址:http://lswzjz.com/article/igecec.html