博客
关于我
强烈建议你试试无所不能的chatGPT,快点击我
Hbase API 写入操作代码,基于hbase-client 1.0.3版本
阅读量:5223 次
发布时间:2019-06-14

本文共 1541 字,大约阅读时间需要 5 分钟。

org.apache.hbase
hbase-client
1.0.3
import org.apache.hadoop.conf.Configuration;import org.apache.hadoop.hbase.HBaseConfiguration;import org.apache.hadoop.hbase.TableName;import org.apache.hadoop.hbase.client.BufferedMutator;import org.apache.hadoop.hbase.client.BufferedMutatorParams;import org.apache.hadoop.hbase.client.Connection;import org.apache.hadoop.hbase.client.ConnectionFactory;import org.apache.hadoop.hbase.client.Put;import org.apache.hadoop.hbase.client.Table;import org.apache.hadoop.hbase.util.Bytes;import java.io.IOException;public class HbaseTest01 {    public static void main(String[] args) throws IOException{        TableName name = TableName.valueOf("testtable");        Configuration conf = HBaseConfiguration.create();        Connection connection = ConnectionFactory.createConnection(conf);        Table table = connection.getTable(name);                BufferedMutator mutator = connection.getBufferedMutator(name);                for (int i = 0; i < 1000000; i++){                        String rowStr = "row"+i;            String valStr = "val"+i;                        Put put = new Put(Bytes.toBytes(rowStr));            put.addColumn(Bytes.toBytes("colfam1"), Bytes.toBytes("qual1"), Bytes.toBytes(valStr));                        mutator.mutate(put);        }                mutator.close();        table.close();        connection.close();         System.out.println("done!");    }}

 

转载于:https://www.cnblogs.com/zhengchunhao/p/5684111.html

你可能感兴趣的文章
css box模型content-box 和border-box
查看>>
Fragment
查看>>
比较安全的获取站点更目录
查看>>
读书笔记——乔布斯,做最好的自己,共创式教练
查看>>
ubuontu16.04安装Opencv库引发的find_package()错误信息处理及其简单使用
查看>>
用Linux远程挂载Windows上的共享文件夹.md
查看>>
洛谷 P4317 花神的数论题(组合数)
查看>>
【Python】学习笔记5-利用flask来mock接口
查看>>
vue
查看>>
MySQL存储过程和存储函数
查看>>
【bzoj 2208】[Jsoi2010]连通数(dfs||Tarjan算法+拓扑序+dp)
查看>>
iis 隐藏 banner
查看>>
leetcode[18]4Sum
查看>>
Java ThreadLocal的使用
查看>>
为什么数据库ID不能作为URL中的标识符
查看>>
Mybatis 3.3.0 Log4j配置
查看>>
JavaScript打开窗口与关闭页面操作大全
查看>>
java 接口参数
查看>>
DP:Skiing(POJ 1088)
查看>>
kudu
查看>>