Hbase之插入数据
2024-10-13 05:24:56
/**
* Created by similarface on 16/8/17.
*/
import org.apache.hadoop.conf.Configuration;
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.Put;
import org.apache.hadoop.hbase.client.Table;
import org.apache.hadoop.hbase.util.Bytes; import java.io.IOException; public class PutExample {
public static void main(String[] args) throws IOException{
//创建必要的参数
Configuration conf = HBaseConfiguration.create();
//初始化客户端
Connection connection=ConnectionFactory.createConnection(conf);
Table table=connection.getTable(TableName.valueOf("testtable"));
//对指定的列创建put对象
Put put = new Put(Bytes.toBytes("row1"));
put.addColumn(Bytes.toBytes("colfam1"),Bytes.toBytes("qual1"),Bytes.toBytes("val1"));
put.addColumn(Bytes.toBytes("colfam1"),Bytes.toBytes("qual2"),Bytes.toBytes("val2"));
table.put(put);
//关闭表
table.close();
//关闭连接
connection.close();
}
}
最新文章
- ob_start()
- Windows下tcp参数优化
- Spring框架学习之第8节
- [转]Android事件分发机制完全解析,带你从源码的角度彻底理解(上)
- OC self super isa指针
- Java学习笔记之:Java的数据类型
- linux测试题
- MyBatis 学习总结(一)
- PHP学习笔记8-文件操作
- win7 64位下如何安装配置mysql-5.7.7-rc-winx64
- 2017年最新chrome必备插件推荐
- flask 扩展之 -- flask-sqlalchemy
- Spring bean中的properties元素内的name 和 ref都代表什么意思啊?
- 我所不知道的Makefile语法
- python实现简单的百度云自动下载
- Oracle表空间不足;查询表空间使用率(unable to extend lob segment SYS_LOB0000076749C00006$$ by 8192 in tablespace USERS)
- 如何创建.gitignore文件,忽略git不必要提交的文件
- AlexNet卷积神经网络【前向反馈】
- 再谈一次关于Java中的 AIO(异步IO) 与 NIO(非阻塞IO)
- [转载] Web Service工作原理及实例