期环境hbase概念及常用api_第1页
期环境hbase概念及常用api_第2页
期环境hbase概念及常用api_第3页
期环境hbase概念及常用api_第4页
期环境hbase概念及常用api_第5页
已阅读5页,还剩70页未读 继续免费阅读

下载本文档

版权说明:本文档由用户提供并上传,收益归属内容提供方,若内容存在侵权,请进行举报或认领

文档简介

1、HBase 基础目录HBase 笔记11 、HBase 集群环境安装22 、HBase Java API 类介绍43 、通过 Java Api 与 HBase 交互84 、HBase s的基本用法155 、Thrift 接口表、数据 246 、Thrift 接口查询、Scan 过滤器356.1、依据行键和列族过滤356.2、据行键开始、行键结束和列族过滤376.3、通过行键前缀进行查询396.4、查找在当前指定时间之前且大于等于 startRowKey 行键; 406.5、查找在当前指定时间之前,在 startRowKeyendRowKey 间行键; 426.6、使用 TScan 过滤器进行过

2、滤,20 种过滤器进行介绍446.6.1、英文介绍446.6.2、行健过滤器(RowFilter)466.6.3、字过滤器(ValueFilter)466.6.4、字段过滤(QualifierFilter)476.6.5、单列值过滤器(SingleColumnValueFilter)476.6.6、单列排除过滤器(SingleColumnValueExcludeFilter)476.6.7、行键前缀过滤器(PrefixFilter)476.6.8、分页过滤器(PageFilter)476.6.9、行键过滤器(KeyOnlyFilter)486.6.10、首次行键过滤器(KeyOnlyFilte

3、r)486.6.11、包含结束的过滤器(InclusiveStopFilter)486.6.12、时间戳过滤器(TimestsFilter)486.6.13、列计数过滤器(ColumnCountGetFilter)486.6.14、列分页过滤器(ColumnPaginationFilter)486.6.15、列前缀过滤器(ColumnPrefixFilter)496.6.16、行键值过滤器(ColumnRangeFilter)496.6.17、单独查询某个字(DependentColumnFilter)496.6.18、列族过滤器(FamilyFilter)496.6.19、多个列前缀过滤器(

4、MultipleColumnPrefixFilter)496.6.20、列式忽略过滤器(SkipFilter)496.6.21、随机行过滤器(RandomRowFilter)506.6.22、具体实现506.6.23、testScan 方法调用527 、客户端 phoenix 安装、运行、创建与 HBase 表同名视图、聚合查询528 、使用客户端 squirrel c nt 连接 phoenix 查询 HBase 数据PLSQL59:HBaseHBase版本地址:/apache/hbase/官网使用向导:1 、HBase 集群环境安装1.1.上传 hbase 安装包通过“SecureCRTP

5、ortable.exe”进行登录到linux 服务器上;AIT + P -新打开一个可上传文件的-注释:转到到指定的目录下sftp cd /home/hadoop/-注释:上传本地路sftp put F:01siteqitools04hbasehbase-0.98.13-hadoop2-bar.gz径文件到服务器上Uploadinghbase-0.98.13-hadoop2-bar.gzto/home/hadoop/hbase-0.98.13-hadoop2-bar.gz100% 85614KB6585KB/s 00:00:13F:/01siteqi/tools/04hbase/hbase-0

6、.98.13-hadoop2-bseconds (6585 KB/s)ar.gz: 87668948 bytes transferred in 13sftp1.2.解压hadoophadoop5 $ tar -zxvf hbase-0.98.13-hadoop2-bar.gz -C /home/hadoop/app/1.3.配置 hbase 集群,要修改 3 个文件(首先 zk 集群已经安装好了)注意:要把 hadoop 的 hdfs-site.xml 和 core-site.xml 放到 hbase/conf 下hadoophadoop7 hadoop$ cd /home/hadoop/ap

7、p/hadoop-2.4.1/etc/hadoophadoophadoop7 hadoop$ cp core-site.xml /home/hadoop/app/hbase-0.98.13-hadoop2/confhadoophadoop7 hadoop$ cp hdfs-site.xml /home/hadoop/app/hbase-0.98.13-hadoop2/conf3.1 修改 hbase-env.shhadoophadoop7 conf$ cd /home/hadoop/app/hbase-0.98.13-hadoop2/confhadoophadoop7 conf$ vi hba

8、se-env.sh/修改实际的 JAVA_HOME 目录地址export JAVA_HOME=/home/hadoop/app/jdk1.7.0_65/告诉 hbase 使用外部的 zkexport HBASE_MANAGES_ZK=false3.2、修改 hbase-site.xmlhadoophadoop7 conf$ vi hbase-site.xmlhbase.rootdirhdfs:/ns1/hbasehbase.cluster.distributedtruehbase.zookeeper.quorumhadoop5:2181,hadoop6:2181,hadoop7:21813.3

9、、修改集群机器hadoophadoop7 conf$ vi regionservershadoop5hadoop6hadoop74.将配置好的 HBase 拷贝到每一个节点并同步时间。拷贝 hbase 到其他节点hadoophadoop5 conf$ cd /home/hadoop/app/hadoophadoop6app$scp-rhbase-0.98.13-hadoop2/hadoophadoop5:/home/hadoop/app/hadoophadoop6app$scp-rhbase-0.98.13-hadoop2/hadoophadoop6:/home/hadoop/app/hado

10、ophadoop6app$scp-rhbase-0.98.13-hadoop2/hadoophadoop7:/home/hadoop/app/5.启动所有的 hbase分别启动 zk./zkServer.sh start启动 hbase 集群start-dfs.sh启动 hbase,在主节点上运行:start-hbase.sh6.通过浏览器hbase 管理页面01:600107.为保证集群的可靠性,要启动多个 HMasterhbase-daemon.sh start master2 、HBase Java API 类介绍java 类HBase 数据模型HBaseAdmin数据库(DataBas

11、e)HBaseConfigurationHTable表(Table)HTableDescriptor列族(Column Family)Put列修饰符(Column Qualifier)几个相关类与 HBase 数据模型之间的对应关系一、HBaseConfiguration二、HBaseAdmin返回值函数描述voidaddColumn(StringtableName,向一个已经存在的表添关系:t.HBaseAdmin作用:提供了一个接口来管理 HBase 数据库的表信息。它提供的方法包括:创建表,删除表,列出表项,使表有效或无效,以及添加或删除表列族成员等。用法示例:HBaseConfigur

12、ation hconfig = new HBaseConfiguration(); hconfig.set(tPort,2181);该方法设置了tPort的端为 2181。一般情况下,HBaseConfiguration 会使用构造函数进行初始化,然后在使用其他方法。返回值函数描述voidaddResource(Path file)通过给定的路径所指的文件来添加资源voidclear()清空所有已设置的属性stringget(String name)获取属性名对应的值Stringget(String name, defaultValue)获取为类型的属性值,如果其属性值类型部位,则返回默认属性

13、值voidset(String name, String value)通过属性名来设置值voidset(String name, value)设置类型的属性值关系:.apache.hadoop.hbase.HBaseConfiguration作用:对 HBase 进行配置GetScanner三、HTableDescriptor用法示例:返回值函数描述voidaddFamily(HColumnDescriptor)添加一个列族HColumnDescriptorremoveFamily(byte column)移除一个列族bytegetName()获取表的名字bytegetValue(byte k

14、ey)获取属性的值voidsetValue(String key, String value)设置属性的值关系:.apache.hadoop.hbase.HTableDescriptor作用:包含了表的名字极其对应表的列族用法示例:HBaseAdmin admin = new HBaseAdmin(config); admin.disableTable(tablename)HColumnDescriptor column)加咧checkHBaseAvailable(HBaseConfiguration conf)静态函数,查看 HBase是否处于运行状态createTable(HTableDe

15、scriptor desc)创建一个表,同步操作deleteTabyte tableName)删除一个已经存在的表enableTabyte tableName)使表处于有效状态disableTabyte tableName)使表处于无效状态HTableDescriptorlistTables()列出所有用户控件表项voidmodifyTabytetableName, HTableDescriptor htd)修改表的模式,是异步的操作,可能需要花费一定的时间tableExists(String tableName)检查表是否存在四、HColumnDescriptor五、HTable返回值函数描

16、述voidcheckAdnPut(byte row, byte family, byte qualifier, byte value, Put put自 动 的 检 查 row/family/qualifier 是否与给定的值匹配voidclose()所有的资源或挂起缓冲区中的更新关系:t.HTable作用:可以用来和 HBase 表直接通信。此方法对于更新操作来说是非线程安全的。用法示例:HTableDescriptor htd = new HTableDescriptor(tablename); HColumnDescriptor col = new HColumnDescriptor(c

17、ontent:); htd.addFamily(col);此例添加了一个 content 的列族返回值函数描述bytegetName()获取列族的名字bytegetValue(byte key)获取对应的属性的值voidsetValue(String key, String value)设置对应属性的值关系: .apache.hadoop.hbase.HColumnDescriptor作用: 着关于列族的信息,例如版本号,压缩设置等。它通常在创建表或者为表添加列族的时候使用。列族被创建后不能直接修改,只能通过删除然后重新创建的方式。列族被删除的时候,列族里面的数据也会同时被删除。HTableD

18、escriptor htd = new HTableDescriptor(table); htd.addFamily(new HcolumnDescriptor(family);在上述例子中,通过一个 HColumnDescriptor 实例,为 HTableDescriptor 添加了一个列族:family六、Put返回值函数描述Putadd(byte family, byte qualifier, byte value)将指定的列和对应的值添加到 Put 实例中Putadd(byte family, byte qualifier, long ts, byte value)将指定的列和对应的

19、值及时间戳添加到Put 实例中bytegetRow()获取 Put 实例的行RowLockgetRowLock()获取 Put 实例的行锁关系:t.Put作用:用来对单个行执行添加操作用法示例:HTable table = new HTable(conf, Bytes.toBytes(tablename); ResultScanner scanner =table.getScanner(family);exists(Get get)检查 Get 实例所指定的值是否存在于HTable 的列中Resultget(Get get)获取指定行的某些单元格所对应的值bytegetEndKeys()获取当

20、前一打开的表每个区域的结束键值ResultScannergetScanner(byte family)获取当前给定列族的 scanner实例获取当前表的HTableDescriptor 实例HTableDescriptetTableDescriptor()bytegetTableName()获取表名sicisTableEnabled(HBaseConfigurationconf, String tableName)检查表是否有效voidput(Put put)向表中添加值七、Get八、Result返回值函数描述containsColumn(byte family, byte qualifier

21、)检查指定的列是否存在关系:t.Result作用:Get 或者 Scan 操作后获取表的单行值。使用此类提供的方法可以直接获取值或者各种 Map 结构(key-value 对)用法示例:HTable table = new HTable(conf, Bytes.toBytes(tablename); Get g = new Get(Bytes.toBytes(row);返回值函数描述GetaddColumn(byte family, byte qualifier)获取指定列族和列修饰符对应的列GetaddFamily(byte family)通过指定的列族获取其对应列的所有列GetsetTim

22、eRange(long minSt,long maxSt)获取指定取件的列的版本号GetsetFilter(Filter filter)当执行 Get 操作时设置服务器端的过滤器关系:t.Get作用:用来获取单个行的相关信息用法示例:HTable table = new HTable(conf,Bytes.toBytes(tablename); Put p = new Put(brow);/为指定行创建一个Put 操作 p.add(family,qualifier,value);table.put(p);longgetTimeSt()获取 Put 实例的时间戳isEmpty()检查 famil

23、yMap 是否为空PutsetTimeSt(long timeSt)设置 Put 实例的时间戳九、ResultScanner3 、通过 Java Api 与 HBase 交互HBase 提供了 Java Api 的接口,掌握这个就跟 Java 应用使用RDBMS 时需要 JDBC一样重要,本文将继续前两篇文章中 blog 表的示例,介绍常用的 Api。import java.io.IOException;import.apache.hadoop.conf.Configuration;import.apache.hadoop.hbase.HBaseConfiguration;import.apa

24、che.hadoop.hbase.HColumnDescriptor;import.apache.hadoop.hbase.HTableDescriptor;import.apache.hadoop.hbase.KeyValue;t.Delete;t.Get;t.HBaseAdmin;返回值函数描述voidclose()关闭scanner 并分配给它的资源Resultnext()获取下一行的值关系:erface作用:客户端获取值的接口NavigableMapgetFamilyMap(byte family)获取对应列族所包含的修饰符与值的键值对bytegetValue(bytefamily,b

25、yte qualifier)获取对应列的值t.HTable;t.HTablePool;t.Put;t.Result;t.ResultScanner;t.Scan;import.apache.hadoop.hbase.util.Bytes;public class Hbase 静态配置/sic Configuration conf = null;sic conf = HBaseConfiguration.create();conf.set(hbase.zookeeper.quorum, localhost);/* 创建表* tableName 表名* family 列族列表*/public si

26、c void creatTable(String tableName, String family)throws Exception HBaseAdmin admin = new HBaseAdmin(conf);HTableDescriptor desc = new HTableDescriptor(tableName);for (i = 0; i family.length; i+) desc.addFamily(new HColumnDescriptor(familyi);if (admableExists(tableName) System.out.prln(table Exists!

27、);System.exit(0); else admin.createTable(desc);System.out.prln(create table Sucs!);/* 为表添加数据(适合知道有多少列族的固定表)* rowKey rowKey* tableName 表名* column1 第一个列族列表* value1 第一个列的值的列表* column2 第二个列族列表* value2 第二个列的值的列表*/public sic void addData(String rowKey, String tableName,String column1, String value1, Strin

28、g column2, String value2)throws IOException Put put = new Put(Bytes.toBytes(rowKey);/ 设置 rowkeyHTable table = new HTable(conf, Bytes.toBytes(tableName);/ HTabel 负责跟的操作如增删改查等/相关/ 获取表HColumnDescriptor columnFamis = table.getTableDescriptor() / 获取所有的列族.getColumnFamis();for (i = 0; i columnFamis.length;

29、 i+) String familyName = columnFamisi.getNameAsString(); / 获取列族名if (familyName.equals(article) / article 列族 put 数据for (j = 0; j column1.length; j+) put.add(Bytes.toBytes(familyName),Bytes.toBytes(column1j), Bytes.toBytes(value1j);if (familyName.equals(author) / author 列族 put 数据for (j = 0; j create s

30、cores,grade, course可以使用list 命令来查看当前HBase 里有哪些表。使用describe 命令来查看表结构。(记得所有的表明、列名都需要加上引号)(2)按设计的表结构值:代码如下:put scores,Tom,grade:,5put scores,Tom,course:math,97put scores,Tom,course:art,87put scores,Jim,grade,4put scores,Jim,course:,89put scores,Jim,course:,80这样表结构就起来了,其实比较加不加冒号都是可以的。,列族里边可以添加子列很方便。如果列族下

31、没有子列,put 命令比较简单,只有这一种用法:hbase put t1, r1, c1, value, ts1t1 指表名,r1 指行键名,c1 指列名,value 指单元格值。ts1 指时间戳,一般都省略掉了。(3)根据键值查询数据get scores,Jimget scores,Jim,grade可能你就发现规律了,HBase 的s操作,一个大概顺序就是操作后跟表名,行名,列名这样的一个顺序,如果有其他条件再用花括号加上。get 有用法如下:hbase get t1, r1hbase get t1, r1, TIMERANGE = ts1, ts2hbase get t1, r1, CO

32、LUMN = c1hbase get t1, r1, COLUMN = c1, c2, c3hbase get t1, r1, COLUMN = c1, TIMEST= ts1hbase get t1, r1, COLUMN = c1, TIMERANGE = ts1, ts2, VER4S =hbase get t1, r1, COLUMN = c1, TIMEST= ts1, VERS = 4hbase get t1, r1, c1hbase get t1, r1, c1, c2hbase get t1, r1, c1, c2(4)扫描所有数据scan scores也可以指定一些修饰词:T

33、IMERANGE, FILTER, LIMIT, STARTROW, STOPROW,TIMEST, MAXLENGTH,or COLUMNS。没任何修饰词,就是上边例句,就会显示所有数据行。例句如下:代码如下:hbase scan .META.hbase scan .META., COLUMNS = info:regioninfohbase scan t1, COLUMNS = c1, c2, LIMIT = 10, STARTROW = xyzhbase scan t1, COLUMNS = c1, TIMERANGE = 1303668804, 1303668904hbase scan

34、t1, FILTER = “(PrefixFilter (row2) AND (QualifierFilter (=,binary:xyz) AND (TimestsFilter ( 123, 456)”hbase scan t1, FILTER =.apache.hadoop.hbase.filter.ColumnPaginationFilter.new(1, 0)过滤器filter 有两种方法:a. Using a filterString more information on this is availableheFilter Languageattached to the HBASE

35、-4176 JIRAb. Using the entire package name of the filter.还有一个CACHE_BLOCKS 修饰词,开关scan 的缓存的,默认是开启的(CACHE_BLOCKS=true),可以选择关闭(CACHE_BLOCKS=false)。(5)删除指定数据代码如下:delete scores,Jim,gradedelete scores,Jim删除数据命令也没太多变化,只有一个:hbase delete t1, r1, c1, ts1另外有一个deleteall 命令,可以进行整行的范围的删除操作,慎用!如果需要进行全表删除操作,就使用trunc

36、ate 命令,其实没有直接的全表删除命令,这个命令也是disable,drop,create 三个命令组合出来的。(6)修改表结构代码如下:disable scoresalter scores,NAME=infoenable scoresalter 命令使用如下(如果无法成功的版本,需要先通用表disable): a、改变或添加一个列族:hbase alter t1, NAME = f1, VERS = 5b、删除一个列族:代码如下:hbase alter t1, NAME = f1, METHOD = delete hbase alter t1, delete = f1c、也可以修改表属性如

37、MAX_FILESIZEMEMSTORE_FLUSHSIZE, READONLY,和 DEFERRED_LOG_FLUSH:hbase alter t1, METHOD = table_att, MAX_FILESIZE = 134217728d、可以添加一个表协同处理器hbase alter t1, METHOD = table_att, coprosor=hdfs:/foo.jar|com.foo.FooRegionObserver|1001|arg1=1,arg2=2一个表上可以配置多个协同处理器,一个序列会自动增长进行标识。加载协同处理器(可以说是过滤程序)需要符合以下规则:copro

38、sor jar file location | claame | priority | argumentse、移除coprosor 如下:hbase alter t1, METHOD = table_att_unset, NAME = MAX_FILESIZEhbase alter t1, METHOD = table_att_unset, NAME = coprof、可以一次执行多个alter 命令:sor$1hbase alter t1, NAME = f1, NAME = f2, METHOD = delete(7)统计行数:代码如下:hbase count t1hbase count

39、t1,ERVAL = 100000hbase count t1, CACHE = 1000hbase count t1,ERVAL = 10, CACHE = 1000count 一般会比较耗时,使用mapreduce 进行统计,统计结果会缓存,默认是 10 行。统计间隔默认的是 1000 行(ERVAL)。(8)disable 和 enable 操作很多操作需要先暂停表的可用性,比如上边说的 alter 操作,删除表也需要这个操作。disable_all和enable_all 能够操作的表。(9)表的删除先停止表的可使用性,然后执行删除命令。drop t1以上是一些常用命令详解,具体的所有h

40、base 的s命令如下,分了几个命令群,看英文是可以看出大概用处的,详细的用法使用help “cmd” 进行了解。代码如下:D GROUPS:Group name: generalds: sus, verGroup name: ddlds: alter, alter_async, alter_sus, create, describe, disable, disable_all, drop,drop_all,enable, enable_all, exists, is_disabled, is_enabled, list, show_filtersGroup name: dmlds: coun

41、t, delete, deleteall, get, get_counter, incr, put, scan, truncateGroup name: toolsds: assign, balance_switch, balancer, close_region, compact, flush, hlog_roll,pact,move, split, unassign, zk_dumpGroup name: replicationds: add_peer, disable_peer, enable_peer, list_peers, remove_peer,start_replication

42、,stop_replicationGroup name: securityds: grant, revoke, user_permishbase s既然是s命令,当然也可以把所有的hbase s命令写入到一个文件内,想linux s程序那样去顺序的执行所有命令。如同写linux s个文件内,然后执行如下命令即可:,把所有hbase s命令书写在一/ggjucheng/p/3379607.html来源:华丽分隔线进入hbase 命令行./hbase s显示hbase 中的表list第一个表名,多个列族create user_info,NAME=base_info,VER=3 ,NAME=extr

43、a_info,VER=1 put user_info, user0000, base_info:name, luoyufengput user_info, user0000, base_info:age, 18put user_info, user0000, base_info:gender, femaleput user_info, user0000, extra_info:size, 34get user_info, user0000create user_info,NAME=base_info ,NAME=extra_infoput user_info, user0001, base_i

44、nfo:name, zhangsan1put user_info, zhangsan_20150701_0001, base_info:name, zhangsan1put user_info, zhangsan_20150701_0002, base_info:name, zhangsan2代码如下:$ hbase stest.hbases方便好用。putuser_info,zhangsan_20150701_0003,base_info:name, zhangsan3putuser_info,zhangsan_20150701_0004,base_info:name, zhangsan4p

45、utuser_info,zhangsan_20150701_0005,base_info:name, zhangsan5putuser_info,zhangsan_20150701_0006,base_info:name, zhangsan6putuser_info,zhangsan_20150701_0007,base_info:name, zhangsan7putuser_info,zhangsan_20150701_0008,base_info:name, zhangsan8putuser_info,zhangsan_20150701_0001,base_info:age, 21putu

46、ser_info,zhangsan_20150701_0002,base_info:age, 22putuser_info,zhangsan_20150701_0003,base_info:age, 23putuser_info,zhangsan_20150701_0004,base_info:age, 24putuser_info,zhangsan_20150701_0005,base_info:age, 25putuser_info,zhangsan_20150701_0006,base_info:age, 26putuser_info,zhangsan_20150701_0007,bas

47、e_info:age, 27putuser_info,zhangsan_20150701_0008,base_info:age, 28putuser_info,zhangsan_20150701_0001,extra_info:Hobbies,musicputuser_info,zhangsan_20150701_0002,extra_info:Hobbies,sportputuser_info,zhangsan_20150701_0003,extra_info:Hobbies, musicputuser_info,zhangsan_20150701_0004,extra_info:Hobbi

48、es, sportputuser_info,zhangsan_20150701_0005,extra_info:Hobbies, musicputuser_info,zhangsan_20150701_0006,extra_info:Hobbies, sportputuser_info,zhangsan_20150701_0007,extra_info:Hobbies, musicputuser_info,baiyc_20150716_0001, base_info:name, baiyc1putuser_info,baiyc_20150716_0002, base_info:name, ba

49、iyc2putuser_info,baiyc_20150716_0003, base_info:name, baiyc3putuser_info,baiyc_20150716_0004, base_info:name, baiyc4putuser_info,baiyc_20150716_0005,base_info:name, baiyc5putuser_info,baiyc_20150716_0006,base_info:name, baiyc6putuser_info,baiyc_20150716_0007,base_info:name, baiyc7putuser_info,baiyc_

50、20150716_0008,base_info:name, baiyc8putuser_info,baiyc_20150716_0001,base_info:age, 21putuser_info,baiyc_20150716_0002,base_info:age, 22putuser_info,baiyc_20150716_0003,base_info:age, 23putuser_info,baiyc_20150716_0004,base_info:age, 24putuser_info,baiyc_20150716_0005,base_info:age, 25putuser_info,b

51、aiyc_20150716_0006,base_info:age, 26putuser_info,baiyc_20150716_0007,base_info:age, 27putuser_info,baiyc_20150716_0008,base_info:age, 28putuser_info,baiyc_20150716_0001,extra_info:Hobbies,musicputuser_info,baiyc_20150716_0002,extra_info:Hobbies,sportputuser_info,baiyc_20150716_0003,extra_info:Hobbie

52、s,musicputuser_info,baiyc_20150716_0004,extra_info:Hobbies,sportputuser_info,baiyc_20150716_0005,extra_info:Hobbies,musicputuser_info,baiyc_20150716_0006,extra_info:Hobbies,sportputuser_info,baiyc_20150716_0007,extra_info:Hobbies,musicputuser_info,baiyc_20150716_0008,extra_info:Hobbies,sportputuser_

53、info,rk0001, base_info:name, luoyufengputuser_info,rk0001, base_info:name, zhangsangetuser_info,rk0001scan user_info, COLUMNS = base_infoscan user_info, COLUMNS = base_info创建user 表,包含info、data 两个列族create user, info1, data1create user, NAME = info, VERS = 3向user 表中信息,row key 为rk0001,列族info 中添加name 列标

54、示符,值为zhangsanput user, rk0001, info:name, zhangsan向user 表中信息,row key 为rk0001,列族info 中添加gender 列标示符,值为femaleput user, rk0001, info:gender, female向user 表中信息,row key 为rk0001,列族info 中添加age 列标示符,值为 20put user, rk0001, info:age, 20向user 表中信息,row key 为rk0001,列族data 中添加pic 列标示符,值为pictureput user, rk0001, da

55、ta:pic, picture获取user 表中row key 为rk0001 的所有信息get user, rk0001获取user 表中row key 为rk0001,info 列族的所有信息get user, rk0001, info获取user 表中row key 为rk0001,info 列族的name、age 列标示符的信息get user, rk0001, info:name, info:age获取user 表中row key 为rk0001,info、data 列族的信息get user, rk0001, info, dataget user, rk0001, COLUMN =

56、 info, dataget user, rk0001, COLUMN = info:name, data:pic获取user 表中row key 为rk0001,列族为info,版本号5 个的信息get user, rk0001, COLUMN = info, VERS =2get user, rk0001, COLUMN = info:name, VERS = 5get user, rk0001, COLUMN = info:name, VERS = 5, TIMERANGE = 1392368783980,1392380169184获取user 表中row key 为rk0001,cel

57、l 的值为zhangsan 的信息get people, rk0001, FILTER = ValueFilter(=, binary:)获取user 表中row key 为rk0001,列标示符中含有a 的信息get people, rk0001, FILTER = (QualifierFilter(=,substring:a)put user, rk0002, info:name, fanbingbingput user, rk0002, info:gender, femaleput user, rk0002, info:nationality, 中国get user, rk0002, F

58、ILTER = ValueFilter(=, binary:中国)查询user 表中的所有信息scan user查询user 表中列族为info 的信息scan user, COLUMNS = infoscan user, COLUMNS = info, RAW = true, VERS = 5scan per, COLUMNS = info, RAW = true, VERS = 3查询user 表中列族为info 和data 的信息scan user, COLUMNS = info, datascan user, COLUMNS = info:name, data:pic查询user 表中

59、列族为info、列标示符为name 的信息scan user, COLUMNS = info:name查询user 表中列族为info、列标示符为name 的信息,并且版本的 5 个scan user, COLUMNS = info:name, VERS = 5查询user 表中列族为info 和data 且列标示符中含有a 字符的信息scan user, COLUMNS = info, data, FILTER = (QualifierFilter(=,substring:a)查询user 表中列族为info,rk 范围是rk0001, rk0003)的数据scan people, COLU

60、MNS = info, STARTROW = rk0001, ENDROW = rk0003查询user 表中row key 以rk 字符开头的scan user,FILTER=PrefixFilter(rk)查询user 表中指定范围的数据scan user, TIMERANGE = 1392368783980, 1392380169184删除数据删除user 表row key 为rk0001,列标示符为info:name 的数据delete people, rk0001, info:name删除user 表row key 为rk0001,列标示符为info:name,timest为 139

温馨提示

  • 1. 本站所有资源如无特殊说明,都需要本地电脑安装OFFICE2007和PDF阅读器。图纸软件为CAD,CAXA,PROE,UG,SolidWorks等.压缩文件请下载最新的WinRAR软件解压。
  • 2. 本站的文档不包含任何第三方提供的附件图纸等,如果需要附件,请联系上传者。文件的所有权益归上传用户所有。
  • 3. 本站RAR压缩包中若带图纸,网页内容里面会有图纸预览,若没有图纸预览就没有图纸。
  • 4. 未经权益所有人同意不得将文件中的内容挪作商业或盈利用途。
  • 5. 人人文库网仅提供信息存储空间,仅对用户上传内容的表现方式做保护处理,对用户上传分享的文档内容本身不做任何修改或编辑,并不能对任何下载内容负责。
  • 6. 下载文件中如有侵权或不适当内容,请与我们联系,我们立即纠正。
  • 7. 本站不保证下载资源的准确性、安全性和完整性, 同时也不承担用户因使用这些下载资源对自己和他人造成任何形式的伤害或损失。

评论

0/150

提交评论