【头歌】HBase扫描与过滤答案 排除复制粘贴限制

 排除复制粘贴限制

当作者遇到这个限制的时间火气起来了三分，然后去网上搜索答案，然后发现了一位【碳烤小肥肠】居然不贴代码，XX链接，贴截图，瞬时火气冲顶，怒写此文

起首启动全能的控制台，然后Ctrl+Shift+F全局搜索这个弹窗

双击进入源码，随便搞个NB的文件夹，然后点击答应

然后右键这个事儿多的js文件，给它更换了

然后在这儿把这玩意儿代码给注释了，然后保存

末了刷新网页，古迹出现，可以复制粘贴了【切勿关闭控制台】


第1关：使用 Shell 下令创建表

1. start-hbase.sh
3. hbase shell
5. create 'exam_tb1','student_info','course_info'
6. put 'exam_tb1', 'row-1', 'student_info:name', 'zhangsan'
7. put 'exam_tb1', 'row-1', 'student_info:s_no', '2020001'
8. put 'exam_tb1', 'row-2', 'student_info:name', 'lisi'
9. put 'exam_tb1', 'row-2', 'student_info:s_no', '2020002'
11. put 'exam_tb1', 'row-1', 'course_info:c_no', '123001'
12. put 'exam_tb1', 'row-1', 'course_info:c_name', 'HBase'
13. put 'exam_tb1', 'row-2', 'course_info:c_no', '123002'
14. put 'exam_tb1', 'row-2', 'course_info:c_name', 'Hadoop'
15. exit
17. echo "scan 'exam_tb1'" | hbase shell >/root/student.txt

复制代码

第2关：使用 Java API 实现增删操作

1. package com.yy;
3. import org.apache.hadoop.conf.Configuration;
4. import org.apache.hadoop.hbase.HBaseConfiguration;
5. import org.apache.hadoop.hbase.TableName;
6. import org.apache.hadoop.hbase.client.*;
7. import org.apache.hadoop.hbase.util.Bytes;
8. import java.util.ArrayList;
9. import java.util.List;
10. import java.io.IOException;
12. public class HbaseUtil {
14.   private static Admin admin = null;
15.   private static Connection connection = null;
16.   private static Configuration conf = null;
18.   static {
19.     // HBase配置文件
20.     conf = HBaseConfiguration.create();
21.     // 获取连接对象
22.     try {
23.       connection = ConnectionFactory.createConnection(conf);
24.       // 获取HBase管理员对象
25.       admin = connection.getAdmin();
26.     } catch (IOException e) {
27.       // TODO Auto-generated catch block
28.       e.printStackTrace();
29.     }
30.   }
31.   private static void close(Connection conn, Admin admin) throws IOException {
32.     if (conn != null) {
33.       conn.close();
34.     }
35.     if (admin != null) {
36.       admin.close();
37.     }
38.   }
40.   //删除exam_tb2表
41.   public void deleteTable() throws IOException {
42.     /**********Begin**********/
43.     admin.disableTable(TableName.valueOf("exam_tb2"));
44.     admin.deleteTable(TableName.valueOf("exam_tb2"));
46.     /**********End**********/
48.   }
50.   //创建exam_tb3表
51.   public void createTab() throws IOException {
53.     /**********Begin**********/
55.     TableName tb3 = TableName.valueOf("exam_tb3");
56.     TableDescriptorBuilder tbd = TableDescriptorBuilder.newBuilder(tb3);
57.     tbd.setColumnFamily(ColumnFamilyDescriptorBuilder.newBuilder(Bytes.toBytes("user_info")).build());
58.     tbd.setColumnFamily(ColumnFamilyDescriptorBuilder.newBuilder(Bytes.toBytes("address_info")).build());
59.     admin.createTable(tbd.build());
61.     /**********End**********/
63.   }
64.   //往exam_tb3表中添加数据
65.   public void putBatch() throws IOException {
66.     /**********Begin**********/
68.     Table table = connection.getTable(TableName.valueOf("exam_tb3"));
69.     Put p1 = new Put(Bytes.toBytes("1"));
70.     Put p2 = new Put(Bytes.toBytes("2"));
71.     Put p3 = new Put(Bytes.toBytes("3"));
72.     p1.addColumn(Bytes.toBytes("user_info"), Bytes.toBytes("name"), Bytes.toBytes("Avatar"));
73.     p1.addColumn(Bytes.toBytes("user_info"), Bytes.toBytes("age"), Bytes.toBytes("100"));
74.     p1.addColumn(Bytes.toBytes("address_info"), Bytes.toBytes("address"), Bytes.toBytes("pandora"));
75.     p1.addColumn(Bytes.toBytes("address_info"), Bytes.toBytes("email"), Bytes.toBytes("avatar@163.com"));
76.     p1.addColumn(Bytes.toBytes("address_info"), Bytes.toBytes("phone"), Bytes.toBytes("123456"));
77.     p2.addColumn(Bytes.toBytes("user_info"), Bytes.toBytes("name"), Bytes.toBytes("change"));
78.     p2.addColumn(Bytes.toBytes("user_info"), Bytes.toBytes("age"), Bytes.toBytes("50"));
79.     p2.addColumn(Bytes.toBytes("address_info"), Bytes.toBytes("address"), Bytes.toBytes("moon"));
80.     p2.addColumn(Bytes.toBytes("address_info"), Bytes.toBytes("email"), Bytes.toBytes("change@163.com"));
81.     p2.addColumn(Bytes.toBytes("address_info"), Bytes.toBytes("phone"), Bytes.toBytes("234567"));
82.     p3.addColumn(Bytes.toBytes("user_info"), Bytes.toBytes("name"), Bytes.toBytes("nezha"));
83.     p3.addColumn(Bytes.toBytes("user_info"), Bytes.toBytes("age"), Bytes.toBytes("6"));
84.     p3.addColumn(Bytes.toBytes("address_info"), Bytes.toBytes("address"), Bytes.toBytes("earth"));
85.     p3.addColumn(Bytes.toBytes("address_info"), Bytes.toBytes("email"), Bytes.toBytes("nezha@163.com"));
86.     p3.addColumn(Bytes.toBytes("address_info"), Bytes.toBytes("phone"), Bytes.toBytes("345678"));
87.     ArrayList < Put > puts = new ArrayList < > ();
88.     puts.add(p1);
89.     puts.add(p2);
90.     puts.add(p3);
91.     table.put(puts);
93.     /**********End**********/
95.   }
97. }

复制代码

第3关：HBase扫描

1. package step3;
3. import java.io.IOException;
5. import org.apache.hadoop.conf.*;
6. import org.apache.hadoop.hbase.*;
7. import org.apache.hadoop.hbase.client.*;
8. import org.apache.hadoop.hbase.util.*;
10. public class Task {
12.   public void scanTable(String tableName) throws Exception {
13.     /********* Begin *********/
15.     Configuration config = HBaseConfiguration.create();
16.     Connection conn = ConnectionFactory.createConnection(config);
17.     Admin admin = conn.getAdmin();
18.     TableName name = TableName.valueOf(tableName);
19.     Table table = conn.getTable(name);
20.     Scan scan = new Scan();
21.     scan.addColumn(Bytes.toBytes("info"), Bytes.toBytes("name"));
22.     scan.setStartRow(Bytes.toBytes("row-10"));
23.     scan.setStopRow(Bytes.toBytes("row-30"));
24.     ResultScanner scanner = table.getScanner(scan);
25.     for (Result result: scanner) {
26.       for (Cell cell: result.listCells()) {
27.         String family = Bytes.toString(CellUtil.cloneFamily(cell));
28.         String qualifier = Bytes.toString(CellUtil.cloneQualifier(cell));
29.         String value = Bytes.toString(CellUtil.cloneValue(cell));
30.         System.out.println("Rowkey:" + Bytes.toString(result.getRow()) + ",ColumuFamily:" + family + ",Column:" + qualifier + ",Value:" + value);
32.           /********* End *********/
33.         }
35.       }
36.     }
37.   }

复制代码

第4关：HBase过滤器

1. package step4;
3. import java.io.IOException;
4. import java.util.ArrayList;
5. import java.util.List;
6. import org.apache.hadoop.conf.Configuration;
7. import org.apache.hadoop.hbase.HBaseConfiguration;
8. import org.apache.hadoop.hbase.TableName;
9. import org.apache.hadoop.hbase.client.Connection;
10. import org.apache.hadoop.hbase.client.ConnectionFactory;
11. import org.apache.hadoop.hbase.client.Result;
12. import org.apache.hadoop.hbase.client.ResultScanner;
13. import org.apache.hadoop.hbase.client.Scan;
14. import org.apache.hadoop.hbase.client.Table;
15. import org.apache.hadoop.hbase.util.Bytes;
17. public class Task {
19.     public void query(String tName) throws Exception {
20.         /********* Begin *********/
21.         Configuration conf = HBaseConfiguration.create();
22.         Connection connection = ConnectionFactory.createConnection(conf);
24.         try {
25.             Table table = connection.getTable(TableName.valueOf(tName));
26.             Scan scan = new Scan();
27.             ResultScanner scanner = table.getScanner(scan);
29.             for (Result result : scanner) {
30.                 byte[] row = result.getRow();
31.                 String rowKey = Bytes.toString(row);
33.                 result.listCells().forEach(cell -> {
34.                     String family = Bytes.toString(cell.getFamilyArray(), cell.getFamilyOffset(), cell.getFamilyLength());
35.                     String qualifier = Bytes.toString(cell.getQualifierArray(), cell.getQualifierOffset(), cell.getQualifierLength());
36.                     String value = Bytes.toString(cell.getValueArray(), cell.getValueOffset(), cell.getValueLength());
38.                     System.out.println(String.format("Rowkey:%s,ColumuFamily:%s,Column:%s,Value:%s", rowKey, family, qualifier, value));
39.                 });
40.             }
42.             scanner.close();
43.             table.close();
44.         } finally {
45.             connection.close();
46.         }
47.         /********* End *********/
48.     }
49. }

复制代码

免责声明：如果侵犯了您的权益，请联系站长，我们会及时删除侵权内容，谢谢合作！更多信息从访问主页：qidao123.com:ToB企服之家，中国第一个企服评测及商务社交产业平台。