package com.cfnet.hadoop.hbase; import java.io.IOException; import java.util.List; import org.apache.hadoop.conf.Configuration; import org.apache.hadoop.hbase.Cell; import org.apache.hadoop.hbase.CellUtil; import org.apache.hadoop.hbase.HBaseConfiguration; import org.apache.hadoop.hbase.HColumnDescriptor; import org.apache.hadoop.hbase.HTableDescriptor; import org.apache.hadoop.hbase.MasterNotRunningException; import org.apache.hadoop.hbase.TableName; import org.apache.hadoop.hbase.ZooKeeperConnectionException; import org.apache.hadoop.hbase.client.Get; import org.apache.hadoop.hbase.client.HBaseAdmin; import org.apache.hadoop.hbase.client.HTable; import org.apache.hadoop.hbase.client.Put; 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.util.Bytes; /** * HBase使用例子 * @author 陶诗德 * */public class HbaseDemo { static Configuration hbaseConfiguration = HBaseConfiguration.create(); static{ hbaseConfiguration.addResource("hbase-site.xml"); } /** * 创建表 * @param tablename 表名 * @param columnFamily 列族 * @throws IOException * @throws ZooKeeperConnectionException * @throws MasterNotRunningException */public static void CreateTable(String tablename,String columnFamily) throws MasterNotRunningException, ZooKeeperConnectionException, IOException{ HBaseAdmin admin = new HBaseAdmin(hbaseConfiguration); if(admin.tableExists(tablename)){//如果表已经存在 System.out.println(tablename+"表已经存在!"); }else{ TableName tableName =TableName.valueOf(tablename); HTableDescriptor tableDesc = new HTableDescriptor(tableName); tableDesc.addFamily(new HColumnDescriptor(columnFamily)); admin.createTable(tableDesc); System.out.println(tablename+"表已经成功创建!"); } } /** * 向表中插入一条新数据 * @param tableName 表名 * @param row 行键key * @param columnFamily 列族 * @param column 列名 * @param data 要插入的数据 * @throws IOException */public static void PutData(String tableName,String row,String columnFamily,String column,String data) throws IOException{ HTable table = new HTable(hbaseConfiguration, tableName); Put put = new Put(Bytes.toBytes(row)); put.add(Bytes.toBytes(columnFamily), Bytes.toBytes(column), Bytes.toBytes(data)); table.put(put); System.out.println("put '"+row+"','"+columnFamily+":"+column+"','"+data+"'"); } /** * 获取指定行的所有数据 * @param tableName 表名 * @param row 行键key * @param columnFamily 列族 * @param column 列名 * @throws IOException */public static void GetData(String tableName,String row,String columnFamily,String column) throws IOException{ HTable table = new HTable(hbaseConfiguration, tableName); // Scan scan = new Scan();// ResultScanner result = table.getScanner(scan); Get get = new Get(Bytes.toBytes(row)); Result result = table.get(get); byte[] rb = result.getValue(Bytes.toBytes(columnFamily), Bytes.toBytes(column)); String value = new String(rb,"UTF-8"); System.out.println(value); } /** * 获取指定表的所有数据 * @param tableName 表名 * @throws IOException */public static void ScanAll(String tableName) throws IOException{ HTable table = new HTable(hbaseConfiguration, tableName); Scan scan = new Scan(); ResultScanner resultScanner = table.getScanner(scan); for (Result result : resultScanner) { List<Cell> cells= result.listCells(); for (Cell cell : cells) { byte[] rb = cell.getValueArray(); String row = new String(result.getRow(),"UTF-8"); String family = new String(CellUtil.cloneFamily(cell),"UTF-8"); String qualifier = new String(CellUtil.cloneQualifier(cell),"UTF-8"); String value = new String(CellUtil.cloneValue(cell),"UTF-8"); System.out.println("[row:"+row+"],[family:"+family+"],[qualifier:"+qualifier+"],[value:"+value+"]"); } } } /** * @param args */public static void main(String[] args) { try { //HbaseDemo.CreateTable("userinfo", "baseinfo");//HbaseDemo.PutData("userinfo", "row2", "baseinfo", "vio2", "驾驶车辆违法信息2:");//HbaseDemo.GetData("userinfo", "row2","baseinfo","vio2"); HbaseDemo.ScanAll("userinfo"); HbaseDemo.ScanAll("userinfo"); } catch (Exception e) { e.printStackTrace(); } } }
- 浏览: 63614 次
- 性别:
- 来自: 北京
相关推荐
Java操作Hbase进行建表、删表以及对数据进行增删改查,条件查询
hbase的sql增删查改例子,该例子的jar都删掉了,只剩下一个,需要自己添加hbase实际运行需要的所有jar包,有什么问题请反馈一下,谢谢!
hadoop-2.52-hbase-0.14-hadoop2 ha高可用安装,hbase动态添加删除节点,hbase集群正常状态及启动,hbase 问题汇总
eclipse构建HBase开发环境并运行实例对Hbase建表增删改查。本次HBase版本为hbase-0.90.5版本,Hadoop版本为Hadoop-0.20.2版本。
hbase各种例子新增修改删除批量导入: public static void main(String[] args) throws IOException { Configuration conf = HBaseConfiguration.create(); HBaseHelper helper = HBaseHelper.getHelper(conf); ...
个人封装的一个Hbase操作帮助类,主要有表的创建、删除、插入、删除、查询(单条件、组合条件查询)等等。写的一般有什么需要改正的地方可留言共同参考
java 利用 sping-data-hadoop HbaseTemplate 操作hbase find get execute 等方法 可以直接运行
java操作hbase,增删查改 版权声明:本文为博主原创文章,未经博主允许不得转载。 https://blog.csdn.net/zhangjingao/article/details/104390560 例子功能说明 不说废话,直接开始,撸代码。hbase的介绍查看其他博...
solr增强hbase检索...1547548620.pdf.
搭建pinpoint需要的hbase初始化脚本hbase-create.hbase
java调用hbase数据库,完成对hbase常用api的封装和对hbase数据库的增删改查等操作,经测试绝对可用。
1. HBase有哪些基本的特征? 1 HBase特征: 1 2. HBase相对于关系数据库能解决的问题是什么? 2 HBase与关系数据的区别? 2 HBase与RDBMS的区别? 2 3. HBase的数据模式是怎么样的?即有哪些元素?如何存储?等 3 1...
HBase(hbase-2.4.9-bin.tar.gz)是一个分布式的、面向列的开源数据库,该技术来源于 Fay Chang 所撰写的Google论文“Bigtable:一个结构化数据的分布式存储系统”。就像Bigtable利用了Google文件系统(File System...
Eclipse工程 HBase MapReduce完整实例 可远程执行 包含HBase增删改查 执行Test可看到效果
hbase-sdk是基于hbase-client和hbase-thrift的原生API封装的一款轻量级的HBase ORM框架。 针对HBase各版本API(1.x~2.x)间的差异,在其上剥离出了一层统一的抽象。并提供了以类SQL的方式来读写HBase表中的数据。对...
hbase java api 访问 增加修改删除(一) 详情请看:http://blog.csdn.net/wild46cat/article/details/53306621
HBase开发实战,HBase学习利器:HBase实战
HBase 官方文档.pdf HBase的操作和编程.pdf HBase Cpressr优化与实验 郭磊涛.pdf null【HBase】Data Migratin frm Gri t Clu Cmputing - Natural Sienes .pdf 分布式数据库HBase快照的设计与实现.pdf 【HBase】...
代码中利用Hbase相关的API,包括对HBase的增删改查等操作,对于初学者学习HBase能够起到作用。 前提是导入hadoop和hbase相关的jar包,可以在hadoop集群上面下载.zip
1. 请用java集合的代码描述HBase的表结构 2. 请简述HBase中数据写入最后导致Region分裂的全过程 3. 如果设计一个笔记的表,表中要求有笔记的属性和笔记的内容,怎么做 4. HBase部署时如何指定多个zookeeper 5. HBase...