HBase 表操作 读写流程

HBase 表操作

创建表

hbase(main)> create ‘student’,‘info’
hbase(main)> create ‘iparkmerchant_order’,‘smzf’
hbase(main)> create ‘staff’,'info’

插入数据到表

hbase(main) > put ‘student2’,‘1001’,cf1:name’,‘Thomas’
hbase(main) > put ‘student2’,‘1001’,‘cf1:sex’,‘male’
hbase(main) > put ‘student2’,‘1001’,‘cf1:age’,‘18’
hbase(main) > put ‘student2’,‘1002’,‘cf1:name’,‘Janna’
hbase(main) > put ‘student2’,‘1002’,‘cf1:sex’,‘female’
hbase(main) > put ‘student2’,‘1002’,‘cf1:age’,'20’

数据插入后的数据模型
HBase 表操作 读写流程

扫描查看表数据

hbase(main) > scan ‘student’
hbase(main) > scan ‘student’,{STARTROW => ‘1001’, STOPROW => ‘1001’}
hbase(main) > scan ‘student’,{STARTROW => '100

注:这个是从哪一个rowkey开始扫描

查看表结构

hbase(main):012:0> desc 'student’

更新指定字段的数据

hbase(main) > put ‘student’,‘1001’,‘info:name’,‘Nick’
hbase(main) > put ‘student’,‘1001’,‘info:age’,‘100’
hbase(main) > put ‘student’,‘1001’,‘info:isNull’,’’(仅测试空值问题)

查看“指定行”或“指定列族:列”的数据

hbase(main) > get ‘student’,‘1001’
hbase(main) > get ‘student’,‘1001’,'info:name’

删除数据

删除某rowkey的全部数据:
hbase(main) > deleteall ‘student’,'1001’

清空表数据

hbase(main) > truncate ‘student’
尖叫提示:清空表的操作顺序为先disable,然后再truncate。

删除表

首先需要先让该表为disable状态:
hbase(main) > disable 'student’

检查这个表是否被禁用

base(main) > is_enabled ‘hbase_book’
hbase(main) > is_disabled ‘hbase_book’
恢复被禁用得表
enable 'student’

然后才能drop这个表:

hbase(main) > drop ‘student’
尖叫提示:如果直接drop表,会报错:Drop the named table. Table must first be disabled
ERROR: Table student is enabled. Disable it first.

统计表数据行数

hbase(main) > count 'student’

变更表信息

将info列族中的数据存放3个版本:
hbase(main) > alter ‘student’,{NAME=>‘info’,VERSIONS=>3}
查看student的最新的版本的数据
hbase(main) > get ‘student’,‘1001’
查看HBase中的多版本
hbase(main) > get ‘student’,‘1001’,{COLUMN=>‘info:name’,VERSIONS=>10}

常用Shell操作

satus 例如:显示服务器状态
hbase> status 'bigdata111’

exists 检查表是否存在,适用于表量特别多的情况
hbase> exists 'hbase_book’

is_enabled/is_disabled 检查表是否启用或禁用
hbase> is_enabled ‘hbase_book’
hbase> is_disabled 'hbase_book’

lter 该命令可以改变表和列族的模式,例如:
为当前表增加列族:
hbase> alter ‘hbase_book’, NAME => ‘CF2’, VERSIONS => 2

为当前表删除列族:
hbase> alter ‘hbase_book’, ‘delete’ => 'CF2’

disable禁用一张表
hbase> disable ‘hbase_book’
hbase> drop 'hbase_book’

delete
删除一行中一个单元格的值,例如:
hbase> delete ‘hbase_book’, ‘rowKey’, 'CF:C’

== truncate清空表数据,即禁用表-删除表-创建表
hbase> truncate ‘hbase_book’==

create
创建多个列族:
hbase> create ‘t1’, {NAME => ‘f1’}, {NAME => ‘f2’}, {NAME => ‘f3’}


读写流程

HBase读数据流程

Hbase的regionserver的内存Memstore,block cache。Memstore作业主要是写,另一部分主要是读的。block cache用的是LRU,如果block cache达到上限,会启动淘汰机制。

(1) HRegionServer保存着.META.的这样一张表以及表数据,要访问表数据,首先Client先去访问zookeeper,从zookeeper里面找到.META.表所在的位置信息,即找到这个.META.表在哪个HRegionServer上保存着。

(2)接着Client通过刚才获取到的HRegionServer的IP来访问.META.表所在的HRegionServer,从而读取到.META.,进而获取到.META.表中存放的元数据。

(3)Client通过元数据中存储的信息,访问对应的HRegionServer,然后扫描(scan)所在
HRegionServer的Memstore如果没有,扫描block cache(读数据的缓存),如果还没有去Storefile来查询数据,查到数据之后将数据读到block cache。

(4)最后HRegionServer把查询到的数据响应给Client。
HBase 表操作 读写流程

HBase写数据流程

(1)Client也是先访问zookeeper,进而找到.META.表,并获取.META.表信息。

(2)确定当前将要写入的数据所对应的RegionServer服务器和Region。

(3)Client向该RegionServer服务器发起写入数据请求,然后RegionServer收到请求并响应。

(4)Client先把数据写入到HLog,以防止数据丢失。

(5)然后将数据写入到Memstore。

(6)如果Hlog和Memstore均写入成功,则这条数据写入成功。在此过程中,如果Memstore达到阈值,会把Memstore中的数据flush到StoreFile中。

(7)当Storefile越来越多,会触发Compact合并操作,把过多的Storefile合并成一个大的Storefile。当Storefile越来越大,Region也会越来越大,达到阈值后,会触发Split操作,将Region一分为二。

尖叫提示:因为内存空间是有限的,所以说溢写过程必定伴随着大量的小文件产生。

HBase 表操作 读写流程