期環(huán)境hbase概念及常用api

1、HBase 基礎(chǔ)目錄HBase 筆記11 、HBase 集群環(huán)境安裝22 、HBase Java API 類介紹43 、通過 Java Api 與 HBase 交互84 、HBase s的基本用法155 、Thrift 接口表、數(shù)據(jù) 246 、Thrift 接口查詢、Scan 過濾器356.1、依據(jù)行鍵和列族過濾356.2、據(jù)行鍵開始、行鍵結(jié)束和列族過濾376.3、通過行鍵前綴進(jìn)行查詢396.4、查找在當(dāng)前指定時(shí)間之前且大于等于 startRowKey 行鍵； 406.5、查找在當(dāng)前指定時(shí)間之前，在 startRowKeyendRowKey 間行鍵； 426.6、使用 TScan 過濾器進(jìn)行過

2、濾，20 種過濾器進(jìn)行介紹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、包含結(jié)束的過濾器（InclusiveStopFilter）486.6.12、時(shí)間戳過濾器（TimestsFilter）486.6.13、列計(jì)數(shù)過濾器（ColumnCountGetFilter）486.6.14、列分頁過濾器（ColumnPaginationFilter）486.6.15、列前綴過濾器（ColumnPrefixFilter）496.6.16、行鍵值過濾器(ColumnRangeFilter)496.6.17、單獨(dú)查詢某個(gè)字(DependentColumnFilter)496.6.18、列族過濾器(FamilyFilter)496.6.19、多個(gè)列前綴過濾器(

4、MultipleColumnPrefixFilter)496.6.20、列式忽略過濾器(SkipFilter)496.6.21、隨機(jī)行過濾器（RandomRowFilter）506.6.22、具體實(shí)現(xiàn)506.6.23、testScan 方法調(diào)用527 、客戶端 phoenix 安裝、運(yùn)行、創(chuàng)建與 HBase 表同名視圖、聚合查詢528 、使用客戶端 squirrel c nt 連接 phoenix 查詢 HBase 數(shù)據(jù)PLSQL59：HBaseHBase版本地址：/apache/hbase/官網(wǎng)使用向?qū)В? 、HBase 集群環(huán)境安裝1.1.上傳 hbase 安裝包通過“SecureCRTP

5、ortable.exe”進(jìn)行登錄到linux 服務(wù)器上；AIT + P -新打開一個(gè)可上傳文件的-注釋：轉(zhuǎn)到到指定的目錄下sftp cd /home/hadoop/-注釋：上傳本地路sftp put F:01siteqitools04hbasehbase-0.98.13-hadoop2-bar.gz徑文件到服務(wù)器上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 個(gè)文件（首先 zk 集群已經(jīng)安裝好了）注意：要把 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/修改實(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、、修改集群機(jī)器hadoophadoop7 conf$ vi regionservershadoop5hadoop6hadoop74.將配置好的 HBase 拷貝到每一個(gè)節(jié)點(diǎn)并同步時(shí)間?？截?hbase 到其他節(jié)點(diǎn)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.啟動(dòng)所有的 hbase分別啟動(dòng) zk./zkServer.sh start啟動(dòng) hbase 集群start-dfs.sh啟動(dòng) hbase，在主節(jié)點(diǎn)上運(yùn)行：start-hbase.sh6.通過瀏覽器hbase 管理頁面01:600107.為保證集群的可靠性，要啟動(dòng)多個(gè) HMasterhbase-daemon.sh start master2 、HBase Java API 類介紹java 類HBase 數(shù)據(jù)模型HBaseAdmin數(shù)據(jù)庫（DataBas

11、e)HBaseConfigurationHTable表（Table)HTableDescriptor列族（Column Family)Put列修飾符（Column Qualifier）幾個(gè)相關(guān)類與 HBase 數(shù)據(jù)模型之間的對(duì)應(yīng)關(guān)系一、HBaseConfiguration二、HBaseAdmin返回值函數(shù)描述voidaddColumn(StringtableName,向一個(gè)已經(jīng)存在的表添關(guān)系：t.HBaseAdmin作用：提供了一個(gè)接口來管理 HBase 數(shù)據(jù)庫的表信息。它提供的方法包括：創(chuàng)建表，刪除表，列出表項(xiàng)，使表有效或無效，以及添加或刪除表列族成員等。用法示例：HBaseConfigur

12、ation hconfig = new HBaseConfiguration(); hconfig.set(tPort,2181);該方法設(shè)置了tPort的端為 2181。一般情況下，HBaseConfiguration 會(huì)使用構(gòu)造函數(shù)進(jìn)行初始化，然后在使用其他方法。返回值函數(shù)描述voidaddResource(Path file)通過給定的路徑所指的文件來添加資源voidclear()清空所有已設(shè)置的屬性stringget(String name)獲取屬性名對(duì)應(yīng)的值Stringget(String name, defaultValue)獲取為類型的屬性值，如果其屬性值類型部位,則返回默認(rèn)屬性

13、值voidset(String name, String value)通過屬性名來設(shè)置值voidset(String name, value)設(shè)置類型的屬性值關(guān)系：.apache.hadoop.hbase.HBaseConfiguration作用：對(duì) HBase 進(jìn)行配置GetScanner三、HTableDescriptor用法示例：返回值函數(shù)描述voidaddFamily(HColumnDescriptor)添加一個(gè)列族HColumnDescriptorremoveFamily(byte column)移除一個(gè)列族bytegetName()獲取表的名字bytegetValue(byte k

14、ey)獲取屬性的值voidsetValue(String key, String value)設(shè)置屬性的值關(guān)系：.apache.hadoop.hbase.HTableDescriptor作用：包含了表的名字極其對(duì)應(yīng)表的列族用法示例：HBaseAdmin admin = new HBaseAdmin(config); admin.disableTable(tablename)HColumnDescriptor column)加咧checkHBaseAvailable(HBaseConfiguration conf)靜態(tài)函數(shù)，查看 HBase是否處于運(yùn)行狀態(tài)createTable(HTableDe

15、scriptor desc)創(chuàng)建一個(gè)表，同步操作deleteTabyte tableName)刪除一個(gè)已經(jīng)存在的表enableTabyte tableName)使表處于有效狀態(tài)disableTabyte tableName)使表處于無效狀態(tài)HTableDescriptorlistTables()列出所有用戶控件表項(xiàng)voidmodifyTabytetableName, HTableDescriptor htd)修改表的模式，是異步的操作，可能需要花費(fèi)一定的時(shí)間tableExists(String tableName)檢查表是否存在四、HColumnDescriptor五、HTable返回值函數(shù)描

16、述voidcheckAdnPut(byte row, byte family, byte qualifier, byte value, Put put自 動(dòng) 的 檢 查 row/family/qualifier 是否與給定的值匹配voidclose()所有的資源或掛起緩沖區(qū)中的更新關(guān)系：t.HTable作用：可以用來和 HBase 表直接通信。此方法對(duì)于更新操作來說是非線程安全的。用法示例：HTableDescriptor htd = new HTableDescriptor(tablename); HColumnDescriptor col = new HColumnDescriptor(c

17、ontent:); htd.addFamily(col);此例添加了一個(gè) content 的列族返回值函數(shù)描述bytegetName()獲取列族的名字bytegetValue(byte key)獲取對(duì)應(yīng)的屬性的值voidsetValue(String key, String value)設(shè)置對(duì)應(yīng)屬性的值關(guān)系： .apache.hadoop.hbase.HColumnDescriptor作用： 著關(guān)于列族的信息，例如版本號(hào)，壓縮設(shè)置等。它通常在創(chuàng)建表或者為表添加列族的時(shí)候使用。列族被創(chuàng)建后不能直接修改，只能通過刪除然后重新創(chuàng)建的方式。列族被刪除的時(shí)候，列族里面的數(shù)據(jù)也會(huì)同時(shí)被刪除。HTableD

18、escriptor htd = new HTableDescriptor(table); htd.addFamily(new HcolumnDescriptor(family);在上述例子中，通過一個(gè) HColumnDescriptor 實(shí)例，為 HTableDescriptor 添加了一個(gè)列族：family六、Put返回值函數(shù)描述Putadd(byte family, byte qualifier, byte value)將指定的列和對(duì)應(yīng)的值添加到 Put 實(shí)例中Putadd(byte family, byte qualifier, long ts, byte value)將指定的列和對(duì)應(yīng)的

19、值及時(shí)間戳添加到Put 實(shí)例中bytegetRow()獲取 Put 實(shí)例的行RowLockgetRowLock()獲取 Put 實(shí)例的行鎖關(guān)系：t.Put作用：用來對(duì)單個(gè)行執(zhí)行添加操作用法示例：HTable table = new HTable(conf, Bytes.toBytes(tablename); ResultScanner scanner =table.getScanner(family);exists(Get get)檢查 Get 實(shí)例所指定的值是否存在于HTable 的列中Resultget(Get get)獲取指定行的某些單元格所對(duì)應(yīng)的值bytegetEndKeys()獲取當(dāng)

20、前一打開的表每個(gè)區(qū)域的結(jié)束鍵值ResultScannergetScanner(byte family)獲取當(dāng)前給定列族的 scanner實(shí)例獲取當(dāng)前表的HTableDescriptor 實(shí)例HTableDescriptetTableDescriptor()bytegetTableName()獲取表名sicisTableEnabled(HBaseConfigurationconf, String tableName)檢查表是否有效voidput(Put put)向表中添加值七、Get八、Result返回值函數(shù)描述containsColumn(byte family, byte qualifier

21、)檢查指定的列是否存在關(guān)系：t.Result作用：Get 或者 Scan 操作后獲取表的單行值。使用此類提供的方法可以直接獲取值或者各種 Map 結(jié)構(gòu)（key-value 對(duì)）用法示例：HTable table = new HTable(conf, Bytes.toBytes(tablename); Get g = new Get(Bytes.toBytes(row);返回值函數(shù)描述GetaddColumn(byte family, byte qualifier)獲取指定列族和列修飾符對(duì)應(yīng)的列GetaddFamily(byte family)通過指定的列族獲取其對(duì)應(yīng)列的所有列GetsetTim

22、eRange(long minSt,long maxSt)獲取指定取件的列的版本號(hào)GetsetFilter(Filter filter)當(dāng)執(zhí)行 Get 操作時(shí)設(shè)置服務(wù)器端的過濾器關(guān)系：t.Get作用：用來獲取單個(gè)行的相關(guān)信息用法示例：HTable table = new HTable(conf,Bytes.toBytes(tablename); Put p = new Put(brow);/為指定行創(chuàng)建一個(gè)Put 操作 p.add(family,qualifier,value);table.put(p);longgetTimeSt()獲取 Put 實(shí)例的時(shí)間戳isEmpty()檢查 famil

23、yMap 是否為空PutsetTimeSt(long timeSt)設(shè)置 Put 實(shí)例的時(shí)間戳九、ResultScanner3 、通過 Java Api 與 HBase 交互HBase 提供了 Java Api 的接口，掌握這個(gè)就跟 Java 應(yīng)用使用RDBMS 時(shí)需要 JDBC一樣重要，本文將繼續(xù)前兩篇文章中 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;返回值函數(shù)描述voidclose()關(guān)閉scanner 并分配給它的資源Resultnext()獲取下一行的值關(guān)系：erface作用：客戶端獲取值的接口NavigableMapgetFamilyMap(byte family)獲取對(duì)應(yīng)列族所包含的修飾符與值的鍵值對(duì)bytegetValue(bytefamily,b

25、yte qualifier)獲取對(duì)應(yīng)列的值t.HTable;t.HTablePool;t.Put;t.Result;t.ResultScanner;t.Scan;import.apache.hadoop.hbase.util.Bytes;public class Hbase 靜態(tài)配置/sic Configuration conf = null;sic conf = HBaseConfiguration.create();conf.set(hbase.zookeeper.quorum, localhost);/* 創(chuàng)建表* 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!);/* 為表添加數(shù)據(jù)（適合知道有多少列族的固定表）* rowKey rowKey* tableName 表名* column1 第一個(gè)列族列表* value1 第一個(gè)列的值的列表* column2 第二個(gè)列族列表* value2 第二個(gè)列的值的列表*/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);/ 設(shè)置 rowkeyHTable table = new HTable(conf, Bytes.toBytes(tableName);/ HTabel 負(fù)責(zé)跟的操作如增刪改查等/相關(guān)/ 獲取表HColumnDescriptor columnFamis = table.getTableDescriptor() / 獲取所有的列族.getColumnFamis();for (i = 0; i columnFamis.length;

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

30、cores,grade, course可以使用list 命令來查看當(dāng)前HBase 里有哪些表。使用describe 命令來查看表結(jié)構(gòu)。（記得所有的表明、列名都需要加上引號(hào)）(2)按設(shè)計(jì)的表結(jié)構(gòu)值：代碼如下: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這樣表結(jié)構(gòu)就起來了，其實(shí)比較加不加冒號(hào)都是可以的。，列族里邊可以添加子列很方便。如果列族下

31、沒有子列，put 命令比較簡(jiǎn)單，只有這一種用法：hbase put t1, r1, c1, value, ts1t1 指表名，r1 指行鍵名，c1 指列名，value 指單元格值。ts1 指時(shí)間戳，一般都省略掉了。(3)根據(jù)鍵值查詢數(shù)據(jù)get scores,Jimget scores,Jim,grade可能你就發(fā)現(xiàn)規(guī)律了，HBase 的s操作，一個(gè)大概順序就是操作后跟表名，行名，列名這樣的一個(gè)順序，如果有其他條件再用花括號(hào)加上。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)掃描所有數(shù)據(jù)scan scores也可以指定一些修飾詞：T

33、IMERANGE, FILTER, LIMIT, STARTROW, STOPROW,TIMEST, MAXLENGTH,or COLUMNS。沒任何修飾詞，就是上邊例句，就會(huì)顯示所有數(shù)據(jù)行。例句如下：代碼如下: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.還有一個(gè)CACHE_BLOCKS 修飾詞，開關(guān)scan 的緩存的，默認(rèn)是開啟的（CACHE_BLOCKS=true），可以選擇關(guān)閉（CACHE_BLOCKS=false）。(5)刪除指定數(shù)據(jù)代碼如下:delete scores,Jim,gradedelete scores,Jim刪除數(shù)據(jù)命令也沒太多變化，只有一個(gè)：hbase delete t1, r1, c1, ts1另外有一個(gè)deleteall 命令，可以進(jìn)行整行的范圍的刪除操作，慎用！如果需要進(jìn)行全表刪除操作，就使用trunc

36、ate 命令，其實(shí)沒有直接的全表刪除命令，這個(gè)命令也是disable，drop，create 三個(gè)命令組合出來的。(6)修改表結(jié)構(gòu)代碼如下:disable scoresalter scores,NAME=infoenable scoresalter 命令使用如下（如果無法成功的版本，需要先通用表disable）： a、改變或添加一個(gè)列族：hbase alter t1, NAME = f1, VERS = 5b、刪除一個(gè)列族：代碼如下: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、可以添加一個(gè)表協(xié)同處理器hbase alter t1, METHOD = table_att, coprosor=hdfs:/foo.jar|com.foo.FooRegionObserver|1001|arg1=1,arg2=2一個(gè)表上可以配置多個(gè)協(xié)同處理器，一個(gè)序列會(huì)自動(dòng)增長(zhǎng)進(jìn)行標(biāo)識(shí)。加載協(xié)同處理器（可以說是過濾程序）需要符合以下規(guī)則：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、可以一次執(zhí)行多個(gè)alter 命令：sor$1hbase alter t1, NAME = f1, NAME = f2, METHOD = delete(7)統(tǒng)計(jì)行數(shù)：代碼如下:hbase count t1hbase count

39、t1,ERVAL = 100000hbase count t1, CACHE = 1000hbase count t1,ERVAL = 10, CACHE = 1000count 一般會(huì)比較耗時(shí)，使用mapreduce 進(jìn)行統(tǒng)計(jì)，統(tǒng)計(jì)結(jié)果會(huì)緩存，默認(rèn)是 10 行。統(tǒng)計(jì)間隔默認(rèn)的是 1000 行（ERVAL）。(8)disable 和 enable 操作很多操作需要先暫停表的可用性，比如上邊說的 alter 操作，刪除表也需要這個(gè)操作。disable_all和enable_all 能夠操作的表。(9)表的刪除先停止表的可使用性，然后執(zhí)行刪除命令。drop t1以上是一些常用命令詳解，具體的所有h

40、base 的s命令如下，分了幾個(gè)命令群，看英文是可以看出大概用處的，詳細(xì)的用法使用help “cmd” 進(jìn)行了解。代碼如下: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命令，當(dāng)然也可以把所有的hbase s命令寫入到一個(gè)文件內(nèi)，想linux s程序那樣去順序的執(zhí)行所有命令。如同寫linux s個(gè)文件內(nèi)，然后執(zhí)行如下命令即可：，把所有hbase s命令書寫在一/ggjucheng/p/3379607.html來源：華麗分隔線進(jìn)入hbase 命令行./hbase s顯示hbase 中的表list第一個(gè)表名，多個(gè)列族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創(chuàng)建user 表，包含info、data 兩個(gè)列族create user, info1, data1create user, NAME = info, VERS = 3向user 表中信息，row key 為rk0001，列族info 中添加name 列標(biāo)

54、示符，值為zhangsanput user, rk0001, info:name, zhangsan向user 表中信息，row key 為rk0001，列族info 中添加gender 列標(biāo)示符，值為femaleput user, rk0001, info:gender, female向user 表中信息，row key 為rk0001，列族info 中添加age 列標(biāo)示符，值為 20put user, rk0001, info:age, 20向user 表中信息，row key 為rk0001，列族data 中添加pic 列標(biāo)示符，值為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 列標(biāo)示符的信息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，版本號(hào)5 個(gè)的信息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，列標(biāo)示符中含有a 的信息get people, rk0001, FILTER = (QualifierFilter(=,substring:a)put user, rk0002, info:name, fanbingbingput user, rk0002, info:gender, femaleput user, rk0002, info:nationality, 中國(guó)get user, rk0002, F

58、ILTER = ValueFilter(=, binary:中國(guó))查詢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、列標(biāo)示符為name 的信息scan user, COLUMNS = info:name查詢user 表中列族為info、列標(biāo)示符為name 的信息,并且版本的 5 個(gè)scan user, COLUMNS = info:name, VERS = 5查詢user 表中列族為info 和data 且列標(biāo)示符中含有a 字符的信息scan user, COLUMNS = info, data, FILTER = (QualifierFilter(=,substring:a)查詢user 表中列族為info，rk 范圍是rk0001, rk0003)的數(shù)據(jù)scan people, COLU

60、MNS = info, STARTROW = rk0001, ENDROW = rk0003查詢user 表中row key 以rk 字符開頭的scan user,FILTER=PrefixFilter(rk)查詢user 表中指定范圍的數(shù)據(jù)scan user, TIMERANGE = 1392368783980, 1392380169184刪除數(shù)據(jù)刪除user 表row key 為rk0001，列標(biāo)示符為info:name 的數(shù)據(jù)delete people, rk0001, info:name刪除user 表row key 為rk0001，列標(biāo)示符為info:name，timest為 139