HBase命令(三) -- 增删改查

摘要:
添加//语法:put<table>,<rowkey>,<family:column>,<value>,<timestamp>//添加或覆盖数据put‘table name‘,‘key name‘,’column name(非列簇名称)‘,‘value‘//如果指定列名下的单元格有值,则覆盖它创建而不带值。所以HBase的添加数据和修改数据是put语句//最后一个时间戳可能不会被写入默认值是系统时间。如果您想写,请记住不要将hbase外壳括在引号中

新增

//语法:put <table>,<rowkey>,<family:column>,<value>,<timestamp>
//新增或者覆盖数据 put '表名','键名','列名(不是列簇名)','值'
//指定的列名下单元格有值就覆盖..没有值就创建.所以HBase的添加数据和修改数据都是put语句..
//最后的时间戳可以不写..默认为系统时间,如果要写..切记不可使用引号括起来

hbase shell> put 'mytable','woshikey','ct:msg','99999999999999'
hbase shell> put 'mytable','woshikey','ct:msg','99999999999999',1462241148

删除 

//删除某个单元值的值  会删除所有版本
//语法:delete <table>, <rowkey>,  <family:column> , <timestamp>,必须指定列名
//测试后发现后边跟时间戳也没有用,依然会删除所有版本
hbase shell> delete 'mytable','rowkey','ct:msg'

//删除行或者整个列簇
//语法:deleteall <table>, <rowkey>,  <family:column> , <timestamp>,可以不指定列名,删除整行数据
hbase shell> deleteall 'mytable','ct'
hbase shell> deleteall 'mytable'

//清空表数据
//语法: truncate <table>
//等同于 disable -> drop -> create
hbase shell> truncate 'mytable'

查询   

//扫描表
//语法: scan <table>, {COLUMNS => [ <family:column>,.... ], LIMIT => num}
hbase shell> scan 'mytable'
hbase shell> scan 'mytable',{COLUMNS=>'ct'}
hbase shell> scan 'mytable',{COLUMNS=>'ct',LIMIT=>1}  //返回所属列簇里每个列的第一个值 
hbase shell> scan 'mytable',{COLUMNS=>'ct:msg',LIMIT=>1}

//获取表数据
//语法: get <table>,<key>[,<columns>]
hbase shell> get 'mytable','rowkey1'
hbase shell> get 'mytable','rowkey1','ct'
hbase shell> get 'mytable','rowkey1','ct:msg'
hbase shell> get 'mytable','rowkey1',{COLUMN=>'ct'}
hbase shell> get 'mytable','rowkey1',{COLUMN=>'ct:msg'}

//获取表行数
//语法:count <table>, {INTERVAL => intervalNum, CACHE => cacheNum}
//INTERVAL设置多少行显示一次及对应的rowkey,默认1000;CACHE每次去取的缓存区大小,默认是10,调整该参数可提高查询速度
//例如,查询表t1中的行数,每100条显示一次,缓存区为500 
hbase shell> count 'mytable', {INTERVAL => 100, CACHE => 500}

免责声明:文章转载自《HBase命令(三) -- 增删改查》仅用于学习参考。如对内容有疑问,请及时联系本站处理。

上篇ORACLE 常用函数——日期/时间函数罗马数字转换阿拉伯数字(Java版,考虑较为全面)下篇

宿迁高防,2C2G15M,22元/月;香港BGP,2C5G5M,25元/月 雨云优惠码:MjYwNzM=

相关文章

flink连接hbase方法及遇到的问题

1、继承 RichSinkFunction 类   mvn配置: <dependency> <groupId>org.apache.flink</groupId> <artifactId>flink-hbase_2.12</artif...

HBase 学习(二) Hbase安装与启动

一,前言 二,前期准备   2.1 文件下载   2.2 服务器准备 三,配置文件配置   3.1 hbase-env.sh   3.2 hbase-site.xml   3.3 regionservers   3.4 将hbase的bin目录添加到环境变量   3.5 Hbase的官方配置文档 四,Hbase服务启动   4.1 Hbase启动   4....

hbase 取多个版本数据

http://jiajun.iteye.com/blog/945358 HBase如何存取多个版本的值? 废话少说,一般情况下使用Put的这个方法保存一个版本: Java代码 /** *AddthespecifiedcolumnandvaluetothisPutoperation. *@paramfamilyfamilyname *@paramq...

HBase丢失数据的故障和原因分析

hbase的稳定性是近期社区的重要关注点,毕竟稳定的系统才能被推广开来,这里有几次稳定性故障和大家分享。第一次生产故障的现象及原因现象: Java代码 1hbase发现无法写入 2通过hbck检测发现.META.表中出现空洞,具体log是:;Chainofregionsintable...isbroken;edgesdoesnotcontain......

Apache NiFi之Kafka流数据到HBase

一.说明 在大数据平台的业务场景中,处理实时kafka数据流数据,以成为必要的能力;此篇将尝试通过Apache NiFi来接入Kafka数据然后处理后存储之HBase 二.开拔 Ⅰ).配置ConsumeKafka_0_10 测试使用了kafka0.10版本,所以NiFi中也选择对于版本 a).选择ConsumeKafka_0_10 在Processor...

JMeter测试HBase

在网上找了关于jmeter连接hbase的方式,主要分为两种:通过导入jar包连接(Java Request)和通过BeanShell远程连接,由于刚接触jmeter没多久,对BeanShell还不熟,所以打算通过eclipse用Java编写连接hbase的程序并打包成jar包,导入到jmeter的方式连接hbase。 HBase本地远程连接HBase是测...