HBase安裝和使用.doc

《HBase安裝和使用.doc》由會員上傳分享，免費(fèi)在線閱讀，更多相關(guān)內(nèi)容在應(yīng)用文檔-天天文庫。

1、.實驗報告..一、Hbase數(shù)據(jù)模型?hbase模式里的邏輯實體包括：?(1)表(table)：HBase用表來組織數(shù)據(jù)。表名是字符串(String)，由可以在文件系統(tǒng)路徑里使用的字符組成。?(2)行(row)：在表里，數(shù)據(jù)按行存儲。行由行鍵(rowkey)唯一標(biāo)識。行鍵沒有數(shù)據(jù)類型，總是視為字節(jié)數(shù)組byte[]。?(3)列族(columnfamily)：行里的數(shù)據(jù)按照列族分組，列族也影響到HBase數(shù)據(jù)的物理存放，因此，它們必須事前定義并且不輕易修改。表中每行擁有相同列族，盡管行不需要在每個列族里存儲數(shù)據(jù)。列族名字是字符串(String)，由可以在文件系統(tǒng)路

2、徑里使用的字符組成。?(4)列限定符(columnqualifier)：列族里的數(shù)據(jù)通過列限定符或列來定位。列限定符不必事前定義，列限定符不必在不同行之間保持一致。就像行鍵一樣，列限定符沒有數(shù)據(jù)類型，總是視為字節(jié)數(shù)組byte[]。?(5)單元(cell)：行鍵、列族和列限定符一起確定一個單元。存儲在單元里的數(shù)據(jù)稱為單元值(value)。值也沒有數(shù)據(jù)類型，總是視為字節(jié)數(shù)組byte[]。?(6)時間版本(version)：單元值有時間版本。時間版本用時間戳標(biāo)識，是一個long。沒有指定時間版本時，當(dāng)前時間戳作為操作的基礎(chǔ)。HBase保留單元值時間版本的數(shù)量基于列族

3、進(jìn)行配置，默認(rèn)數(shù)量是3個。?HBase的每個數(shù)據(jù)值使用坐標(biāo)來訪問。一個值的完整坐標(biāo)包括行鍵、列族、列限定符和時間版本。由于把所有坐標(biāo)視為一個整體，因此HBase可以看作是一個鍵值(key-value)數(shù)據(jù)庫。二、Hbase分布式部署1、下載發(fā)布包到HBase官方下載最新的版本hbase-1.2.6-hadoop2-bin.tar.gz..$tarxfzhbase-1.2.6-hadoop2-bin.tar.gz$cdhbase-1.2.6-hadoop22、配置系統(tǒng)環(huán)境sudovim/etc/profilesource/etc/profileexportHBA

4、SE_HOME="/usr/local/share/hbase"exportPATH=$HBASE_HOME/bin:$PATH3、修改配置文件：/conf/hbase-site.xmlhbase.rootdirhdfs://localhost:9000/hbasehbase.cluster.distributedtrue

5、alue>4、演示4.1、啟動HBase：4.2、shell演示建表、插入數(shù)據(jù)、查詢數(shù)據(jù)、刪除表..一、使用Java客戶端對對自定的表進(jìn)行CURD操作Java代碼：publicclassmyHbase{??????privatestaticConfigurationconf=null;???static{??????conf=HBaseConfiguration.create();???}???/**???*columnfamilysaddcolumn<--->hbasecolumnName..???*@paramtableName???

6、*@paramfamilys???*@throwsException???*/???publicvoidcreateTable(StringtableName,String[]familys)throwsException{??????HBaseAdminadmin=newHBaseAdmin(conf);??????if(!admin.tableExists(tableName)){?????????HTableDescriptordesc=newHTableDescriptor(tableName);?????????for(inti=0;i

7、s.length;i++){????????????desc.addFamily(newHColumnDescriptor(familys[i]));?????????}??????????admin.createTable(desc);???????}else{?????????System.out.println("thetable:"+tableName+"exsists");??????};???}???/**???*@paramtableName???*@paramrowKey???*@paramfamily???*@paramqualifier??

8、?*@paramvalue???*@t