HBase shell命令整理
2016-03-23 17:40
399 查看
创建hbase表:
create 'T_YYXT_GTGL_CPZXWTXX', 'QUSINFO'
删除表:
disable 'T_YYXT_HYGL_JBXX2'
drop 'T_YYXT_HYGL_JBXX2'
清空表:
truncate 'T_YYXT_GC_FILE'
新增列族
alter ‘表名’,NAME=>’列族名称’
例如: alter ‘user’,NAME=>’class’
删除列族
alter ‘表名’,NAME=>’列族名称’,METHOD=>’delete’
例如:alter ‘user’,NAME=>’class’,METHOD=>’delete’
删除表
在使用drop删除一个表之前,必须先将该表disable:
disable ‘user’
drop ‘user’
表添加记录
put ‘表名’,’rowkey’,’列族名称:列名称’,’值’
put ‘user’,’1’,’info:name’,’zhangsan’
查看数据
get ‘表名’,’rowkey’
例如:get ‘user’,’1’
查看列数据
get ‘表名’,’rowkey’,’列族名称:列名称’
例如:get ‘user’,’1’,’info:name’
删除数据
deleteall ‘表名称’,’rowkey’
例如:deleteall ‘user’,’1’
删除列数据
delete ‘表名称’,’rowkey’,’列族名称:列名称’
例如:delete ‘user’,’1’,’info:name’
Hbase的导入导出
导出
hbase org.apache.hadoop.hbase.mapreduce.Export T_SYS_SEQUENCE /hbase/data_backup/T_SYS_SEQUENCE_20151009_001
hbase org.apache.hadoop.hbase.mapreduce.Export T_SYS_KEY /hbase/data_backup/T_SYS_KEY_20151009_001
下载文件
hadoop fs -get /hbase/data_backup/T_SYS_SEQUENCE_20151009_001 /wdcloud/data/hbase/data_backup/T_SYS_SEQUENCE_20151009_001
hadoop fs -get /hbase/data_backup/T_SYS_KEY_20151009_001 /wdcloud/data/hbase/data_backup/T_SYS_KEY_20151009_001
hbase需要有过滤查询的时候
import org.apache.hadoop.hbase.filter.CompareFilter
import org.apache.hadoop.hbase.filter.SingleColumnValueFilter
import org.apache.hadoop.hbase.filter.SubstringComparator
import org.apache.hadoop.hbase.util.Bytes
scan 'T_YYXT_JYGL_DDJSXX', { COLUMNS => 'INFO:YJJSRQ', FILTER =>SingleColumnValueFilter.new(Bytes.toBytes('INFO'),Bytes.toBytes('YJJSRQ'),CompareFilter::CompareOp.valueOf('LESS'),Bytes.toBytes("20160126015059111"))}
scan 'T_YYXT_GC_FILE', { COLUMNS => 'FILE:YWID', FILTER =>SingleColumnValueFilter.new(Bytes.toBytes('FILE'),Bytes.toBytes('YWID'),CompareFilter::CompareOp.valueOf('EQUAL'),Bytes.toBytes("1100000000000001442"))}
create 'T_YYXT_GTGL_CPZXWTXX', 'QUSINFO'
删除表:
disable 'T_YYXT_HYGL_JBXX2'
drop 'T_YYXT_HYGL_JBXX2'
清空表:
truncate 'T_YYXT_GC_FILE'
新增列族
alter ‘表名’,NAME=>’列族名称’
例如: alter ‘user’,NAME=>’class’
删除列族
alter ‘表名’,NAME=>’列族名称’,METHOD=>’delete’
例如:alter ‘user’,NAME=>’class’,METHOD=>’delete’
删除表
在使用drop删除一个表之前,必须先将该表disable:
disable ‘user’
drop ‘user’
表添加记录
put ‘表名’,’rowkey’,’列族名称:列名称’,’值’
put ‘user’,’1’,’info:name’,’zhangsan’
查看数据
get ‘表名’,’rowkey’
例如:get ‘user’,’1’
查看列数据
get ‘表名’,’rowkey’,’列族名称:列名称’
例如:get ‘user’,’1’,’info:name’
删除数据
deleteall ‘表名称’,’rowkey’
例如:deleteall ‘user’,’1’
删除列数据
delete ‘表名称’,’rowkey’,’列族名称:列名称’
例如:delete ‘user’,’1’,’info:name’
Hbase的导入导出
导出
hbase org.apache.hadoop.hbase.mapreduce.Export T_SYS_SEQUENCE /hbase/data_backup/T_SYS_SEQUENCE_20151009_001
hbase org.apache.hadoop.hbase.mapreduce.Export T_SYS_KEY /hbase/data_backup/T_SYS_KEY_20151009_001
下载文件
hadoop fs -get /hbase/data_backup/T_SYS_SEQUENCE_20151009_001 /wdcloud/data/hbase/data_backup/T_SYS_SEQUENCE_20151009_001
hadoop fs -get /hbase/data_backup/T_SYS_KEY_20151009_001 /wdcloud/data/hbase/data_backup/T_SYS_KEY_20151009_001
hbase需要有过滤查询的时候
import org.apache.hadoop.hbase.filter.CompareFilter
import org.apache.hadoop.hbase.filter.SingleColumnValueFilter
import org.apache.hadoop.hbase.filter.SubstringComparator
import org.apache.hadoop.hbase.util.Bytes
scan 'T_YYXT_JYGL_DDJSXX', { COLUMNS => 'INFO:YJJSRQ', FILTER =>SingleColumnValueFilter.new(Bytes.toBytes('INFO'),Bytes.toBytes('YJJSRQ'),CompareFilter::CompareOp.valueOf('LESS'),Bytes.toBytes("20160126015059111"))}
scan 'T_YYXT_GC_FILE', { COLUMNS => 'FILE:YWID', FILTER =>SingleColumnValueFilter.new(Bytes.toBytes('FILE'),Bytes.toBytes('YWID'),CompareFilter::CompareOp.valueOf('EQUAL'),Bytes.toBytes("1100000000000001442"))}
相关文章推荐
- linux命令---shell脚本调试
- 重定位shell
- Shell编程(八)---输入输出重定向、文件包含
- Xshell连接设备,切入串口操作的方式
- Shell编程(七)---函数
- shell队列实现线程并发控制
- Shell编程(六)---循环
- Shell编程(五)---if、case
- linux邮件发送测试 直接shell/smpt发送
- Shell编程(四)---echo、printf
- 二进制安装mysql的shell脚本
- 安卓通用android adb shell 命令大全
- bash实现两个文件的并交减集合操作
- linux_shell
- shell编程之正则表达式
- shell编程笔记
- shell--读取文件
- Bash脚本学习(1)
- 用python实时获取shell命令的输出[rsync备份进度]
- Linux Shell编程基础