亚洲在线久爱草,狠狠天天香蕉网,天天搞日日干久草,伊人亚洲日本欧美

為了賬號安全,請及時綁定郵箱和手機立即綁定

HBase基礎和數據導入

標簽:
Java

创建表hbase_test有两个列族CF1和CF2

  • 向表中添加数据,在向HBase的表中添加数据的时候,只能一列一列的添加,不能同时添加多列。
    create 'hbase_test',{NAME=>'cf1'},{NAME=>'cf2'}
    put 'hbase_test', '001','cf1:name','liz';
    put 'hbase_test', '001','cf1:age','11';
    put 'hbase_test', '001','cf1:phone','1598791111';
    put 'hbase_test', '001','cf1:address','南京';
  • 查看表中的所有数据
    scan 'hbase_test'
  • 查看其中某一个Key的数据
    get 'hbase_test','001'
  • hbase的表支持动态加入列的,比如说列族cf下面有两列,再添加数据时,可以在动态的加一列。

Hbase导入功能的实现:

  • 直接导入到表

    新建测试表
    create 'hbase_import',{NAME=>'cf1'},{NAME=>'cf2'}
    创建数据 上传到HDFS
    vi hbase_import.txt 
    1,"tom",18
    2,"liz",19
    3,"xiami",22
    hadoop fs -put /home/hadoop/data/hbase_import.txt /data
    导入
    bin/hbase org.apache.hadoop.hbase.mapreduce.ImportTsv -Dimporttsv.separator="," -Dimporttsv.columns=HBASE_ROW_KEY,cf1:name,cf1:age hbase_import  hdfs://hadoop001:8020/data/hbase_import.txt
  • 生成Hfile的导入方式
create 'hbase_import01',{NAME=>'cf1'},{NAME=>'cf2'}
上传文件
hadoop fs -put /home/hadoop/data/hbase_import01.txt /data
生成HFile(指定输出文件路径 表名称  和输入路径)
hbase org.apache.hadoop.hbase.mapreduce.ImportTsv '-Dimporttsv.separator=,' -Dimporttsv.columns='HBASE_ROW_KEY,cf1:name,cf1:age' -Dimporttsv.bulk.output=hdfs://hadoop001:8020/data/hbase/test/output hbase_import01 hdfs://hadoop001:8020/data/hbase/test
执行LoadIncrementalHFiles把HFile注册到hbase中
hbase org.apache.hadoop.hbase.mapreduce.LoadIncrementalHFiles hdfs://hadoop001:8020/data/hbase/test/output  hbase_import01

参考

https://blog.csdn.net/zzq900503/article/details/79643855
點擊查看更多內容
TA 點贊

若覺得本文不錯,就分享一下吧!

評論

作者其他優質文章

正在加載中
JAVA開發工程師
手記
粉絲
6390
獲贊與收藏
157

關注作者,訂閱最新文章

閱讀免費教程

  • 推薦
  • 評論
  • 收藏
  • 共同學習,寫下你的評論
感謝您的支持,我會繼續努力的~
掃碼打賞,你說多少就多少
贊賞金額會直接到老師賬戶
支付方式
打開微信掃一掃,即可進行掃碼打賞哦
今天注冊有機會得

100積分直接送

付費專欄免費學

大額優惠券免費領

立即參與 放棄機會
微信客服

購課補貼
聯系客服咨詢優惠詳情

幫助反饋 APP下載

慕課網APP
您的移動學習伙伴

公眾號

掃描二維碼
關注慕課網微信公眾號

舉報

0/150
提交
取消