主机参考:VPS测评参考推荐/专注分享VPS服务器优惠信息!若您是商家可以在本站进行投稿,查看详情!此外我们还提供软文收录、PayPal代付、广告赞助等服务,查看详情! |
我们发布的部分优惠活动文章可能存在时效性,购买时建议在本站搜索商家名称可查看相关文章充分了解该商家!若非中文页面可使用Edge浏览器同步翻译!PayPal代付/收录合作 |
HBase 允许您使用 Put
类添加数据。 下面是一个简单的示例,展示了如何使用 Put
类向 HBase 表添加数据。
导入 org.apache.hadoop.hbase.client.Connection;
导入 org.apache.hadoop.hbase.client。 ConnectionFactory;
导入 org.apache.hadoop.hbase.client.Put;
导入 org.apache.hadoop.hbase.client.Table;
导入 org.apache.hadoop.hbase.util.Bytes;
public class HBasePutExample {
公共 静态void main(String[] args) {
尝试一下 {
// 创建 HBase 连接
连接 连接 = ConnectionFactory.createConnection( );
//获取HBase表
表 表 = connection.getTable(TableName.valueOf("my_table")) ;
// 创建 Put 对象并指定 row key。
放置 放置 = 新建 放置(Bytes.toBytes("row1"));
// 添加列族、列和值到 Put 对象
put.addColumn(Bytes.toBytes ( "cf1"), Bytes.toBytes("col1"), Bytes.toBytes("value1"));
// Put 向 HBase 表中插入一个对象
桌子。 put(put);
//关闭连接
table.close();
connection.close();
} catch (异常 e) {
e.printStackTrace();
}
}
}
在上面的例子中,首先创建一个HBase连接,然后检索指定的HBase表。 然后创建一个 Put
对象,指定行键,并使用 addColumn</ 将列族、列和值添加到
Put
对象中。将被添加。 代码 > 方法。 最后,将 Put
对象插入到 HBase 表中并关闭连接。 这样您就可以将数据添加到 HBase 表中。
这几篇文章你可能也喜欢:
- 如何删除hbase表中的列簇
- 显示hbase中表数据的命令是什么(显示hbase中所有表)
- 如何加快Spark中hbase数据的慢读取速度(将spark数据导入hbase)
- 如何读取hive中的hbase数据(hive hadoop hbase)
- 如何将hbase表映射到hive外部表(hbase外部表)
本文由主机参考刊发,转载请注明:如何使用put in hbase添加数据(hbase导入数据方法) https://zhujicankao.com/132023.html
评论前必须登录!
注册