试验4熟悉常用的HBase操作VIP专享VIP免费

实验4熟悉常用的HBase操作实验4熟悉常用的HBase操作姓名：包生友专业年级：软件143学号：20140126991.实验目的1.理解HBase在Hadoop体系结构中的角色；2.熟练使用HBase操作常用的Shell命令；3.熟悉HBase操作常用的JavaAPI。2.实验环境操作系统：LinuxHadoop版本：2.6.0或以上版本HBase版本：1.1.2或以上版本JDK版本：1.6或以上版本JavaIDE：Eclipse3.实验内容和完成情况1.编程实现以下指定功能，并用Hadoop提供的HBaseShell命令完成相同任务：（完整可执行代码见代码/QuestionOne.java）（1）列出HBase所有的表的相关信息，例如表名；Shell:List图1列出HBase所有表的相关信息编程：//(1)列出HBase所有的表的相关信息，例如表名、创建时间等publicstaticvoidlistTables()throwsIOException{init();//建立连接HTableDescriptorhTableDescriptors[]=admin.listTables();实验4熟悉常用的HBase操作for(HTableDescriptorhTableDescriptor:hTableDescriptors){System.out.println("表名:"+hTableDescriptor.getNameAsString());}close();//关闭连接}（2）在终端打印出指定的表的所有记录数据；Shell:scan's1'图2打印指定表的所有记录数据编程：//(2)在终端打印出指定的表的所有记录数据publicstaticvoidgetData(StringtableName)throwsIOException{init();Tabletable=connection.getTable(TableName.valueOf(tableName));Scanscan=newScan();ResultScannerscanner=table.getScanner(scan);for(Resultresult:scanner){printRecoder(result);}close();}//打印一条记录的详情publicstaticvoidprintRecoder(Resultresult)throwsIOException{for(Cellcell:result.rawCells()){System.out.print("行健:"+newString(CellUtil.cloneRow(cell)));System.out.print("列簇:"+newString(CellUtil.cloneFamily(cell)));System.out.print("列:"+newString(CellUtil.cloneQualifier(cell)));System.out.print("值:"+newString(CellUtil.cloneValue(cell)));实验4熟悉常用的HBase操作System.out.println("时间戳:"+cell.getTimestamp());}}（3）向已经创建好的表添加和删除指定的列族或列；p.s：此题请先在Shell中创建s1作为示例表:create's1','score'a)在s1表,添加数据：Shell:put's1','zhangsan','score:Math','69'图3给s1添加数据编程：//向表添加数据publicstaticvoidinsertRow(StringtableName,StringrowKey,StringcolFamily,Stringcol,Stringval)throwsIOException{init();Tabletable=connection.getTable(TableName.valueOf(tableName));Putput=newPut(rowKey.getBytes());put.addColumn(colFamily.getBytes(),col.getBytes(),val.getBytes());table.put(put);table.close();close();}insertRow("s1",'zhangsan','score','Math','69')b)在s1表，删除指定的列：Shell:实验4熟悉常用的HBase操作delete's1','zhangsan','score:Math'图4删除数据编程：//删除数据publicstaticvoiddeleteRow(StringtableName,StringrowKey,StringcolFamily,Stringcol)throwsIOException{init();Tabletable=connection.getTable(TableName.valueOf(tableName));Deletedelete=newDelete(rowKey.getBytes());//删除指定列族delete.addFamily(Bytes.toBytes(colFamily));//删除指定列delete.addColumn(Bytes.toBytes(colFamily),Bytes.toBytes(col));table.delete(delete);table.close();close();}deleteRow("s1",'zhangsan','score','Math')（4）清空指定的表的所有记录数据；Shell:truncate's1'实验4熟悉常用的HBase操作图5清空指定表的所有记录数据编程://(4)清空指定的表的所有记录数据publicstaticvoidclearRows(StringtableName)throwsIOException{init();TableNametablename=TableName.valueOf(tableName);admin.disableTable(tablename);admin.deleteTable(tablename);HTableDescriptorhTableDescriptor=newHTableDescriptor(tableName);admin.createTable(hTableDescriptor);close();}（5）统计表的行数。Shell:count's1'图6统计表的行数编程：//(5)统计表的行数publicstaticvoidcountRows(StringtableName)throwsIOE...