利用 HTable创建客户端,并向HBase插入数据
2017-05-31 16:39
357 查看
1,hbase文件结构图
2,创建客户端的方法二:
利用HTable,可进行增删改查操作。/** * 利用 HTable创建客户端,并向HBase插入数据 * Created by zhaojy on 2017/5/17. */ public class HBaseTest { private final static String HB_ZK_QUORUM="10.8.177.27,10.8.177.28,10.8.177.29"; private final static String HB_ZK_PORT="2181"; public static void main(String args[])throws Exception{ //创建配置 Configuration conf = HBaseConfiguration.create(); //设置zk地址和端口号 conf.set("hbase.zookeeper.property.clientPort", HB_ZK_PORT); conf.set("hbase.zookeeper.quorum",HB_ZK_QUORUM); //实例化一个新的配置 HTable table = new HTable(conf,"testTable"); // 指定一行创建put Put put = new Put(Bytes.toBytes("row1")); //像Put中添加名为 colfam1:qul1 的列 put.addColumn(Bytes.toBytes("colfam1"),Bytes.toBytes("qual1"),Bytes.toBytes("val1")); put.addColumn(Bytes.toBytes("colfam1"),Bytes.toBytes("qual2"),Bytes.toBytes("val2")); put.addColumn(Bytes.toBytes("colfam1"),Bytes.toBytes("qual3"),Bytes.toBytes("val3")); //将这一行存储到HBase表中。 table.put(put); } }
相关文章推荐
- hbase总结:插入数据的表名不存在或和创建的表名不一致
- java实现hbase表创建、数据插入、删除表
- 利用SQL存储过程创建表的插入数据语句(用于到别处还原整张表)
- 2018-08-18期 Hbase客户端API操作( 插入数据)
- hbase中创建表、插入数据,更新数据,删除数据
- hbase学习-- 4 使用HBase客户端API 创建和更新数据
- 创建shell脚本,利用for循环箱向日志文件中插入n条数据
- Java 向Hbase表插入数据异常org.apache.hadoop.hbase.client.HTablePool$PooledHTable cannot be cast to org.apache.client.HTable
- 一个利用创建临时表后插入数据的查询
- Java连接HBASE数据库,创建一个表,删除一张表,修改表,输出插入,修改,数据删除,数据获取,显示表信息,过滤查询,分页查询,地理hash
- 利用mapreduce计算框架向hbase插入数据(python脚本)
- hbase中创建表、插入数据,更新数据,删除数据
- HBase 学习之一 <<HBase使用客户端API动态创建Hbase数据表并在Hbase下导出执行>>
- Hbase创建表插入查询数据案例
- java实现hbase表创建、数据插入、删除表
- java实现hbase表创建、数据插入、删除表
- Hbase笔记:使用hbaseAPI实现表的创建与循环数据插入
- C#自动给据sql中的带@的变量提取变量名称在从简单数据对象中取得生成SqlParameter数组进行数据插入(利用反射完成)
- 利用 WCF duplex Service 【推送】数据到Siliverlight客户端 的双向通讯例子
- 利用序列插入批量数据