Hbase如何使用

1355913552 • 09/07 18:55 • Linux技术 • 93 views

这篇文章主要介绍了Hbase如何使用，具有一定借鉴价值，感兴趣的朋友可以参考下，希望大家阅读完这篇文章之后大有收获，下面让小编带着大家一起了解一下。与mysql 对比：1 创建表只需要指定famliy 列族，不需要指定具体的列以及类型@PostConstructpublic boolean createTable() {log.info(“create table start”);TableName tableName = TableName.valueOf(this.getTableName());try { Admin admin = connection.getAdmin();if (!admin.tableExists(tableName)) {log.info(tableName.toString() + “is not exist,create it”); HTableDescriptor tdesc = new HTableDescriptor(tableName); HColumnDescriptor colDesc = new HColumnDescriptor(FAMILY); tdesc.addFamily(colDesc); admin.createTable(tdesc); admin.close();}log.info(“create table end”);return true;} catch (IOException e) { log.error(“create table error {} {}”, tableName, e.getLocalizedMessage());return false;}}2 存储数据格式 HBASE value全部采用byte[] 字节数据形式存储优势：1 不需要提前处理数据类型统一采用 Bytes.toByte() so 存储速度更高2 与原始数据类型相比,序列化后的byte[] 形式存储可以节省字节3 可以根据rowKey 进行范围查找，这个需要将rowKey设计得当。@Overridepublic List getByRange(String start, String end) {try {Table table = connection.getTable(TableName.valueOf(getTableName()));Scan scan = new Scan();scan.withStartRow(start.getBytes(), true) .withStopRow(end.getBytes(), true);Re 香港云主机sultScanner scanner = table.getScanner(scan);List list = new ArrayList();for (Result result : scanner) {list.add(getObj(result));}return list;} catch (Exception e) {log.error(“HBase批量获取数据失败”, e);}return Collections.emptyList();}感谢你能够认真阅读完这篇文章，希望小编分享的“Hbase如何使用”这篇文章对大家有帮助，同时也希望大家多多支持开发云，关注开发云行业资讯频道，更多相关知识等着你来学习!