实验4熟悉常用的HBase操作.docxVIP

实验4熟悉常用的 HBase 操作 姓名：包生友专业年级：软件143 学号：2014012699 1.实验目的 1. 理解 HBase 在 Hadoop 体系结构中的角色； 2. 熟练使用HBase 操作常用的Shell命令； 3. 熟悉HBase 操作常用的Java API。 2.实验环境 操作系统： Linux Hadoop 版本：2.6.0或以上版本 HBase 版本：1.1.2或以上版本 JDK 版本：1.6或以上版本 Java IDE:Eclipse 3.实验内容和完成情况 1. 编程实现以下指定功能，并用 Hadoop 提供的 HBase Shell 命令完成相同任务： (完整可执行代码见代码/QuestionOne.java) (1)列出HBase 所有的表的相关信息，例如表名； Shell: List hbase(main):601:0 Ltst TABLE s1 1 row(s)in 0.1690 seconds [s1] 图1 列出HBase 所有表的相关信息 编程： //(1)列出HBase 所有的表的相关信息，例如表名、创建时间等 public static void listTables() throws IOException { init();//建立连接 HTableDescriptor hTableDescriptors[]= admin.listTables(); for(HTableDescriptor hTableDescriptor :hTableDescriptors){ System.out.println(表名：+hTableDescriptor.getNameAsString(0)); } close();//关闭连接 (2)在终端打印出指定的表的所有记录数据； Shell: scan s1 hbase(main):002:0 hbase(main):002:0 scans1 RON COLUMN+CELL o row(s)in 0.1380 seconds 图2打印指定表的所有记录数据 编程： //(2)在终端打印出指定的表的所有记录数据 public static void getData(String tableName)throws IOException{ init(); Table table = connection.getTable(TableName.valueOf(tableName)); Scan scan = new Scan(); ResultScanner scanner =table.getScanner(scan); for (Result result:scanner){ printRecoder(result); } close( 一 //打印一条记录的详情 public static void printRecoder(Result result)throws IOException{ for(Cell cell:result.rawCells(){ System.out.print(行健：+new String(CellUtil.cloneRow(cell); System.out.print(列簇：+new String(CellUtil.cloneFamily(cell))); System.out.print( 列：+new String(CellUtil.cloneQualifier(cell))); System.out.print( 值：+new String(CellUtil.cloneValue(cell)); System.out.println(时间戳：+cell.getTimestamp()); } (3)向已经创建好的表添加和删除指定的列族或列； p.S: 此题请先在Shell中创建s1 作为示例表：createsl,score a) 在 s1 表，添加数据： Shell: putsl,zhangsan,score:Math,69 hbase(matn):003:0 hbase(matn):003:0 puts1,zhangsan,score:Math,69 o r?w(s)in 0.0600 seconds hbase(main):004:0 ls NameError: undefined local vartable or methodls for #object:0xb903aee hbase(