0
0

头歌 HBase（相关的五个实验）

HBase的安装与基本操作

第一关：HBase数据库的安装与配置

mkdir /app

cd /opt

tar -zxvf hbase-2.1.1-bin.tar.gz -C /app

vim /app/hbase-2.1.1/conf/hbase-env.sh

vi中的操作：按i编写下面这行代码在文件末尾(换英文键盘输入）

export JAVA_HOME=/usr/lib/jvm/jdk1.8.0_111

vi中的操作：按键盘的esc键

shift + : 输入wq保存退出

下面两步一样

vi /app/hbase-2.1.1/conf/hbase-site.xml

<configuration> <property> 
  1.    <name>hbase.rootdir</name>
  3.    <value>file:///root/data/hbase/data</value>
</property> <property> 
  1.    <name>hbase.zookeeper.property.dataDir</name>
  3.    <value>/root/data/hbase/zookeeper</value>
</property> <property>

<name>hbase.unsafe.stream.capability.enforce</name>

  1.     <value>false</value>
</property> </configuration>

vim /etc/profile

SET HBASE_enviroment

HBASE_HOME=/app/hbase-2.1.1

export PATH=$PATH:$HBASE_HOME/bin

source /etc/profile

start-hbase.sh

第二关：创建表

hbase shell
回车
create 'test','data'
回车
create 'dept','data'
回车
create 'emp','data'
回车
list
测评

第三关：添加数据，删除数据

启动 HBase 一行一次

start-hbase.sh

进入 hbase shell

hbase shell
create 'mytable','data'
put 'mytable','row1','data:1','zhangsan'
put 'mytable','row2','data:2','zhangsanfeng'
put 'mytable','row3','data:3','zhangwuji'

退出

exit

HBase 伪分布式环境搭建

下面这位博主的亲测详细有用

Fdecad的博客_CSDN博客-数据结构,头歌实训,配置环境领域博主

HBase 开发：使用Java操作HBase

第1关：创建表

代码文件

  1. package step1;
  3. import java.io.IOException;
  4. import org.apache.hadoop.conf.Configuration;
  5. import org.apache.hadoop.hbase.HBaseConfiguration;
  6. import org.apache.hadoop.hbase.HColumnDescriptor;
  7. import org.apache.hadoop.hbase.HTableDescriptor;
  8. import org.apache.hadoop.hbase.TableName;
  9. import org.apache.hadoop.hbase.client.Admin;
  10. import org.apache.hadoop.hbase.client.ColumnFamilyDescriptor;
  11. import org.apache.hadoop.hbase.client.ColumnFamilyDescriptorBuilder;
  12. import org.apache.hadoop.hbase.client.Connection;
  13. import org.apache.hadoop.hbase.client.ConnectionFactory;
  14. import org.apache.hadoop.hbase.client.Get;
  15. import org.apache.hadoop.hbase.client.Put;
  16. import org.apache.hadoop.hbase.client.Result;
  17. import org.apache.hadoop.hbase.client.ResultScanner;
  18. import org.apache.hadoop.hbase.client.Scan;
  19. import org.apache.hadoop.hbase.client.Table;
  20. import org.apache.hadoop.hbase.client.TableDescriptor;
  21. import org.apache.hadoop.hbase.client.TableDescriptorBuilder;
  22. import org.apache.hadoop.hbase.util.Bytes;
  24. public class Task{
  25.     
  26.     public void createTable()throws Exception{
  27.         /********* Begin *********/
  28.         Configuration config = HBaseConfiguration.create();
  30. Connection connection = ConnectionFactory.createConnection(config);
  32. try {
  34. // Create table
  36. Admin admin = connection.getAdmin();
  38. try {
  40. TableName tableName = TableName.valueOf("dept");
  42. // 新 API 构建表
  44. // TableDescriptor 对象通过 TableDescriptorBuilder 构建；
  46. TableDescriptorBuilder tableDescriptor =
  48. TableDescriptorBuilder.newBuilder(tableName);
  50. ColumnFamilyDescriptor family =
  52. ColumnFamilyDescriptorBuilder.newBuilder(Bytes.toBytes("data")).build();// 构建列族对象
  54. tableDescriptor.setColumnFamily(family); // 设置列族
  56. admin.createTable(tableDescriptor.build()); // 创建表
  58.  
  60. TableName emp = TableName.valueOf("emp");
  62. // 新 API 构建表
  64. // TableDescriptor 对象通过 TableDescriptorBuilder 构建；
  66. TableDescriptorBuilder empDescriptor =
  68. TableDescriptorBuilder.newBuilder(emp);
  70. ColumnFamilyDescriptor empfamily =
  72. ColumnFamilyDescriptorBuilder.newBuilder(Bytes.toBytes("emp")).build();// 构建列族对象
  74. empDescriptor.setColumnFamily(empfamily); // 设置列族
  76. admin.createTable(empDescriptor.build()); // 创建表
  78. } finally {
  80. admin.close();
  82. }
  84. } finally {
  86. connection.close();
  88. }
  90.         /********* End *********/
  91.     }
  92. }

命令行

start-dfs.sh

回车

start-hbase.sh

回车

第2关：添加数据

代码文件

  1. package step2;
  3. import java.io.IOException;
  5. import org.apache.hadoop.conf.Configuration;
  7. import org.apache.hadoop.hbase.HBaseConfiguration;
  9. import org.apache.hadoop.hbase.HColumnDescriptor;
  11. import org.apache.hadoop.hbase.HTableDescriptor;
  13. import org.apache.hadoop.hbase.TableName;
  15. import org.apache.hadoop.hbase.client.Admin;
  17. import org.apache.hadoop.hbase.client.ColumnFamilyDescriptor;
  19. import org.apache.hadoop.hbase.client.ColumnFamilyDescriptorBuilder;
  21. import org.apache.hadoop.hbase.client.Connection;
  23. import org.apache.hadoop.hbase.client.ConnectionFactory;
  25. import org.apache.hadoop.hbase.client.Get;
  27. import org.apache.hadoop.hbase.client.Put;
  29. import org.apache.hadoop.hbase.client.Result;
  31. import org.apache.hadoop.hbase.client.ResultScanner;
  33. import org.apache.hadoop.hbase.client.Scan;
  35. import org.apache.hadoop.hbase.client.Table;
  37. import org.apache.hadoop.hbase.client.TableDescriptor;
  39. import org.apache.hadoop.hbase.client.TableDescriptorBuilder;
  41. import org.apache.hadoop.hbase.util.Bytes;
  43. public class Task {
  45.  public void insertInfo()throws Exception{
  47.  /********* Begin *********/
  49.  Configuration config = HBaseConfiguration.create();
  51.  Connection connection = ConnectionFactory.createConnection(config);
  53.  Admin admin = connection.getAdmin();
  55.  TableName tableName = TableName.valueOf("tb_step2");
  57.  TableDescriptorBuilder tableDescriptor = TableDescriptorBuilder.newBuilder(tableName);
  59.  ColumnFamilyDescriptor family = ColumnFamilyDescriptorBuilder.newBuilder(Bytes.toBytes("data")).build();//  构建列族对象
  61.  tableDescriptor.setColumnFamily(family); //  设置列族
  63.  admin.createTable(tableDescriptor.build()); //  创建表
  65.  // 添加数据
  67.  byte[] row1 = Bytes.toBytes("row1");
  69.  Put put1 = new Put(row1); 
  71.  byte[] columnFamily1 = Bytes.toBytes("data"); // 列
  73.  byte[] qualifier1 = Bytes.toBytes(String.valueOf(1)); // 列族修饰词
  75.  byte[] value1 = Bytes.toBytes("张三丰"); // 值
  77.  put1.addColumn(columnFamily1, qualifier1, value1);
  79.  byte[] row2 = Bytes.toBytes("row2");
  81.  Put put2 = new Put(row2); 
  83.  byte[] columnFamily2 = Bytes.toBytes("data"); // 列
  85.  byte[] qualifier2 = Bytes.toBytes(String.valueOf(2)); // 列族修饰词
  87.  byte[] value2 = Bytes.toBytes("张无忌"); // 值
  89.  put2.addColumn(columnFamily2, qualifier2, value2);
  91.  Table table = connection.getTable(tableName);
  93.  table.put(put1);
  95.  table.put(put2);
  97.  /********* End *********/
  99.  }
  101. }

命令行

start-dfs.sh

回车

start-hbase.sh

回车

第3关：获取数据

代码文件

  1. package step3;
  3. import java.io.IOException;
  5. import org.apache.hadoop.conf.Configuration;
  7. import org.apache.hadoop.hbase.HBaseConfiguration;
  9. import org.apache.hadoop.hbase.HColumnDescriptor;
  11. import org.apache.hadoop.hbase.HTableDescriptor;
  13. import org.apache.hadoop.hbase.TableName;
  15. import org.apache.hadoop.hbase.client.Admin;
  17. import org.apache.hadoop.hbase.client.ColumnFamilyDescriptor;
  19. import org.apache.hadoop.hbase.client.ColumnFamilyDescriptorBuilder;
  21. import org.apache.hadoop.hbase.client.Connection;
  23. import org.apache.hadoop.hbase.client.ConnectionFactory;
  25. import org.apache.hadoop.hbase.client.Get;
  27. import org.apache.hadoop.hbase.client.Put;
  29. import org.apache.hadoop.hbase.client.Result;
  31. import org.apache.hadoop.hbase.client.ResultScanner;
  33. import org.apache.hadoop.hbase.client.Scan;
  35. import org.apache.hadoop.hbase.client.Table;
  37. import org.apache.hadoop.hbase.client.TableDescriptor;
  39. import org.apache.hadoop.hbase.client.TableDescriptorBuilder;
  41. import org.apache.hadoop.hbase.util.Bytes;
  43. public class Task {
  45.  public void queryTableInfo()throws Exception{
  47.  /********* Begin *********/
  49.  Configuration config = HBaseConfiguration.create();
  51.  Connection connection = ConnectionFactory.createConnection(config);
  53.  Admin admin = connection.getAdmin();
  55.  TableName tableName = TableName.valueOf("t_step3");
  57.  Table table = connection.getTable(tableName);
  59.  // 获取数据
  61.  Get get = new Get(Bytes.toBytes("row1")); // 定义 get 对象
  63.  Result result = table.get(get); // 通过 table 对象获取数据
  65.  //System.out.println("Result: " + result);
  67.  // 很多时候我们只需要获取“值”   这里表示获取  data:1  列族的值
  69.  byte[] valueBytes = result.getValue(Bytes.toBytes("data"), Bytes.toBytes("1")); // 获取到的是字节数组
  71.  // 将字节转成字符串
  73.  String valueStr = new String(valueBytes,"utf-8");
  75.  System.out.println("value:" + valueStr);
  77.  TableName tableStep3Name = TableName.valueOf("table_step3");
  79.  Table step3Table = connection.getTable(tableStep3Name);
  81.  // 批量查询
  83.  Scan scan = new Scan();
  85.  ResultScanner scanner = step3Table.getScanner(scan);
  87.  try {
  89.  int i = 0;
  91.  for (Result scannerResult: scanner) {
  93.  //byte[] value = scannerResult.getValue(Bytes.toBytes("data"), Bytes.toBytes(1));
  95.  // System.out.println("Scan: " + scannerResult);
  97.  byte[] row = scannerResult.getRow();
  99.  System.out.println("rowName:" + new String(row,"utf-8"));
  101.  }
  103.  } finally {
  105.  scanner.close();
  107.  }
  109.  /********* End *********/
  111.  }
  113. }

命令行

start-dfs.sh

回车

start-hbase.sh

回车

第4关：删除表

代码文件

  1. package step4;
  3. import java.io.IOException;
  5. import org.apache.hadoop.conf.Configuration;
  7. import org.apache.hadoop.hbase.HBaseConfiguration;
  9. import org.apache.hadoop.hbase.HColumnDescriptor;
  11. import org.apache.hadoop.hbase.HTableDescriptor;
  13. import org.apache.hadoop.hbase.TableName;
  15. import org.apache.hadoop.hbase.client.Admin;
  17. import org.apache.hadoop.hbase.client.ColumnFamilyDescriptor;
  19. import org.apache.hadoop.hbase.client.ColumnFamilyDescriptorBuilder;
  21. import org.apache.hadoop.hbase.client.Connection;
  23. import org.apache.hadoop.hbase.client.ConnectionFactory;
  25. import org.apache.hadoop.hbase.client.Get;
  27. import org.apache.hadoop.hbase.client.Put;
  29. import org.apache.hadoop.hbase.client.Result;
  31. import org.apache.hadoop.hbase.client.ResultScanner;
  33. import org.apache.hadoop.hbase.client.Scan;
  35. import org.apache.hadoop.hbase.client.Table;
  37. import org.apache.hadoop.hbase.client.TableDescriptor;
  39. import org.apache.hadoop.hbase.client.TableDescriptorBuilder;
  41. import org.apache.hadoop.hbase.util.Bytes;
  43. public class Task {
  45.  public void deleteTable()throws Exception{
  47.  /********* Begin *********/
  49.  Configuration config = HBaseConfiguration.create();
  51.  Connection connection = ConnectionFactory.createConnection(config);
  53.  Admin admin = connection.getAdmin();
  55.  TableName tableName = TableName.valueOf("t_step4");
  57.  admin.disableTable(tableName);
  59.  admin.deleteTable(tableName);
  61.  /********* End *********/
  63.  }
  65. }

命令行

start-dfs.sh

回车

start-hbase.sh

回车

HBase 开发：批量操作

第1关：批量获取数据

代码文件

  1. package step1;
  2. import java.io.IOException;
  3. import java.util.ArrayList;
  4. import java.util.List;
  5. import org.apache.hadoop.conf.Configuration;
  6. import org.apache.hadoop.hbase.Cell;
  7. import org.apache.hadoop.hbase.CellScanner;
  8. import org.apache.hadoop.hbase.CellUtil;
  9. import org.apache.hadoop.hbase.HBaseConfiguration;
  10. import org.apache.hadoop.hbase.TableName;
  11. import org.apache.hadoop.hbase.client.Admin;
  12. import org.apache.hadoop.hbase.client.Connection;
  13. import org.apache.hadoop.hbase.client.ConnectionFactory;
  14. import org.apache.hadoop.hbase.client.Get;
  15. import org.apache.hadoop.hbase.client.HTable;
  16. import org.apache.hadoop.hbase.client.Result;
  17. import org.apache.hadoop.hbase.client.ResultScanner;
  18. import org.apache.hadoop.hbase.client.Scan;
  19. import org.apache.hadoop.hbase.client.Table;
  20. import org.apache.hadoop.hbase.client.TableDescriptor;
  21. import org.apache.hadoop.hbase.generated.rest.rest_jsp;
  22. import org.apache.hadoop.hbase.util.Bytes;
  23. public class Task {
  24.  public void batchGet() throws Exception {
  25.    /********* Begin *********/
  26.  Configuration config = HBaseConfiguration.create();
  27.    Connection Connection = ConnectionFactory.createConnection(config);
  28.    List<String> rows = new ArrayList<>();
  29.    rows.add("2018");
  30.    //rows.add("2019");
  31.    rows.add("2020");
  32.    TableName tableName = TableName.valueOf(Bytes.toBytes("step1_student"));
  33.    Table table = Connection.getTable(tableName);
  34.    getData(table,rows);
  35.    /********* End *********/
  36.  }
  37. public List<String> getData(Table table, List<String> rows) throws Exception {
  38.  List<Get> gets = new ArrayList<>();
  39.  for (String str : rows) {
  40.  Get get = new Get(Bytes.toBytes(str));
  41.  gets.add(get);
  42.  }
  43.  List<String> values = new ArrayList<>();
  44.  Result[] results = table.get(gets);
  45.  for (Result result : results) {
  46.  System.out.println("Row:" + Bytes.toString(result.getRow()));
  47.  for (Cell kv : result.rawCells()) {
  48.  String family = Bytes.toString(CellUtil.cloneFamily(kv));
  49.  String qualifire = Bytes.toString(CellUtil.cloneQualifier(kv));
  50.  String value = Bytes.toString(CellUtil.cloneValue(kv));
  51.  values.add(value);
  52.  System.out.println(family + ":" + qualifire + "\t" + value);
  53.  }
  54.  }
  55.  return values;
  56. }
  57. }

命令行

start-dfs.sh

回车

start-hbase.sh

回车

第2关：批量删除数据

代码文件

  1. package step2;
  2. import java.io.IOException;
  3. import java.util.ArrayList;
  4. import java.util.HashMap;
  5. import java.util.List;
  6. import java.util.Map;
  7. import org.apache.hadoop.conf.Configuration;
  8. import org.apache.hadoop.hbase.HBaseConfiguration;
  9. import org.apache.hadoop.hbase.HColumnDescriptor;
  10. import org.apache.hadoop.hbase.HTableDescriptor;
  11. import org.apache.hadoop.hbase.TableDescriptors;
  12. import org.apache.hadoop.hbase.TableName;
  13. import org.apache.hadoop.hbase.client.*;
  14. import org.apache.hadoop.hbase.util.Bytes;
  15. public class Task {
  16.  public void batchDelete()throws Exception{
  17.    /********* Begin *********/
  18.  Configuration conf = HBaseConfiguration.create();
  19.  
  20.  Connection conn = ConnectionFactory.createConnection(conf);
  21.  
  22.  TableName tableName = TableName.valueOf("step2_table");
  23.  Table table = conn.getTable(tableName);
  24.  List<String> rows1 = new ArrayList();
  25.  for(int i = 1; i<6;i++){
  26.  String row = "row" + i;
  27.  rows1.add(row);
  28.  }
  29.  delete(table,rows1);
  30.  List<String> rows2 = new ArrayList<>();
  31.  for(int i = 7;i<11;i++){
  32.  String row = "row" + i;
  33.  rows2.add(row);
  34.  }
  35.  
  36.  delete(table,rows2);
  37.    
  38.    /********* End *********/
  39.  }
  40.  public void delete(Table table,List<String> rows)throws IOException{
  41.  List<Delete> deletes = new ArrayList<>();
  42.  for(String str : rows){
  43.  byte[] row = Bytes.toBytes(str);
  44.  Delete delete = new Delete(row);
  45.  deletes.add(delete);
  46.  }
  47.  table.delete(deletes);
  48. }
  49. }

命令行

start-dfs.sh

回车

start-hbase.sh

回车

第3关：批量导入数据至HBase

代码文件

  1. package step3;
  2. import java.io.IOException;
  3. import java.util.ArrayList;
  4. import java.util.HashMap;
  5. import java.util.List;
  6. import java.util.Map;
  7. import org.apache.hadoop.conf.Configuration;
  8. import org.apache.hadoop.hbase.HBaseConfiguration;
  9. import org.apache.hadoop.hbase.HColumnDescriptor;
  10. import org.apache.hadoop.hbase.HTableDescriptor;
  11. import org.apache.hadoop.hbase.TableDescriptors;
  12. import org.apache.hadoop.hbase.TableName;
  13. import org.apache.hadoop.hbase.client.Admin;
  14. import org.apache.hadoop.hbase.client.ColumnFamilyDescriptor;
  15. import org.apache.hadoop.hbase.client.ColumnFamilyDescriptorBuilder;
  16. import org.apache.hadoop.hbase.client.Connection;
  17. import org.apache.hadoop.hbase.client.ConnectionFactory;
  18. import org.apache.hadoop.hbase.client.Get;
  19. import org.apache.hadoop.hbase.client.Put;
  20. import org.apache.hadoop.hbase.client.Result;
  21. import org.apache.hadoop.hbase.client.ResultScanner;
  22. import org.apache.hadoop.hbase.client.Scan;
  23. import org.apache.hadoop.hbase.client.Table;
  24. import org.apache.hadoop.hbase.client.TableDescriptor;
  25. import org.apache.hadoop.hbase.client.TableDescriptorBuilder;
  26. import org.apache.hadoop.hbase.util.Bytes;
  27. public class Task {
  28.  public void batchPut()throws Exception{
  29.    /********* Begin *********/
  30.    Configuration config = new Configuration();
  31.    Connection conn = ConnectionFactory.createConnection(config);
  32.    Admin admin = conn.getAdmin();
  33.    // 建表
  34.    TableName tableName = TableName.valueOf(Bytes.toBytes("stu"));
  35.    TableDescriptorBuilder builder = TableDescriptorBuilder.newBuilder(tableName);
  36.    ColumnFamilyDescriptor family = ColumnFamilyDescriptorBuilder.newBuilder(Bytes.toBytes("basic_info")).build();
  37.    ColumnFamilyDescriptor family2 = ColumnFamilyDescriptorBuilder.newBuilder(Bytes.toBytes("school_info")).build();
  38.    builder.setColumnFamily(family);
  39.    builder.setColumnFamily(family2);
  40.    admin.createTable(builder.build());
  41.    List<Put> puts = new ArrayList<>();
  42.    String[] rows = {"20181122","20181123"};
  43.    String[][] basic_infos = {{"阿克蒙德","male","1987-05-23","tel:139********","HUNan-ChangSha"},{"萨格拉斯","male","1986-05-23","tel:187********","HUNan-ChangSha"}};
  44.    String[] basic_colums = {"name","gender","birthday","connect","address"};
  45.    String[][] school_infos = {{"ChengXing","class 1 grade 2","Software"},{"ChengXing","class 2 grade 2","Software"}};
  46.    String[] school_colums = {"college","class","object"};
  47.    for (int x = 0; x < rows.length; x++) {
  48.      // 循环添加数据
  49.      Put put = new Put(Bytes.toBytes(rows[x]));
  50.      for (int i = 0; i < basic_infos.length; i++) {
  51.        byte[] columFamily = Bytes.toBytes("basic_info");
  52.        byte[] qualifier = Bytes.toBytes(basic_colums[i]);
  53.        byte[] value = Bytes.toBytes(basic_infos[x][i]);
  54.        put.addColumn(columFamily, qualifier, value);
  55.      }
  56.      for (int i = 0; i < school_infos.length; i++) {
  57.        byte[] columFamily = Bytes.toBytes("school_info");
  58.        byte[] qualifier = Bytes.toBytes(school_colums[i]);
  59.        byte[] value = Bytes.toBytes(school_infos[x][i]);
  60.        put.addColumn(columFamily, qualifier, value);
  61.      }
  62.      puts.add(put);
  63.    }
  64.    Table table = conn.getTable(tableName);
  65.    table.put(puts);
  66.    /********* End *********/
  67.  }
  68. }

命令行

start-dfs.sh

回车

start-hbase.sh

回车

HBase开发： Java API 管理表

第1关：JavaAPI获取表的列表

代码文件

  1. package step1;
  2.  
  3. import java.util.ArrayList;
  4. import java.util.List;
  5.  
  6. import org.apache.hadoop.conf.*;
  7. import org.apache.hadoop.hbase.*;
  8. import org.apache.hadoop.hbase.client.*;
  9. import org.apache.hadoop.hbase.util.*;
  10.  
  11. public class Task {
  12.  
  13.     public void showTableList() throws Exception {
  14.         /********* Begin *********/
  15.         Configuration conf = HBaseConfiguration.create(); //使用create()静态方法就可以得到Configuration对象
  16.         Connection conn = ConnectionFactory.createConnection(conf); //config为前文的配置对象
  17.         Admin admin = conn.getAdmin(); //使用连接对象获取Admin对象
  18.         List<TableDescriptor> tableDescriptors = admin.listTableDescriptors();
  19.         for(TableDescriptor tableDescriptor: tableDescriptors){
  20.             System.out.println("Table：" + tableDescriptor.getTableName());
  21.             System.out.println("\texists：" + admin.tableExists(tableDescriptor.getTableName()));
  22.             System.out.println("\tenabled：" + admin.isTableEnabled(tableDescriptor.getTableName()));
  23.         }
  24.         
  25.  
  26.  
  27.  
  28.         /********* End *********/
  29.     }
  30. }

第2关：修改表

代码文件

  1.     package step2;
  2.  
  3. import java.io.IOException;
  4.  
  5.  
  6. import org.apache.hadoop.conf.*;
  7. import org.apache.hadoop.hbase.*;
  8. import org.apache.hadoop.hbase.client.*;
  9. import org.apache.hadoop.hbase.io.compress.Compression;
  10. import org.apache.hadoop.hbase.util.*;
  11.  
  12. public class Task {
  13.     
  14.     public void updateTables()throws Exception{
  15.         /********* Begin *********/
  16.         Configuration conf = HBaseConfiguration.create(); //使用create()静态方法就可以得到Configuration对象
  17.         Connection conn = ConnectionFactory.createConnection(conf); //config为前文的配置对象
  18.         Admin admin = conn.getAdmin(); //使用连接对象获取Admin对象
  19.         TableName tableName1 = TableName.valueOf("t_emp2");
  20.         TableName tableName2 = TableName.valueOf("t_dept2");
  21.                 ColumnFamilyDescriptorBuilder buildFamily = ColumnFamilyDescriptorBuilder.newBuilder(Bytes.toBytes("data"));//创建builder对象
  22.                 buildFamily.setBlocksize(1024*1024);//设置缓存大小
  23.                 buildFamily.setBlockCacheEnabled(false);//设置关闭缓存，默认是true
  24.                 buildFamily.setCompressionType(Compression.Algorithm.GZ);//默认是NONE
  25.                 ColumnFamilyDescriptor family = buildFamily.build();//构建Family对象
  26.                 admin.modifyColumnFamily(tableName1, family);//调用修改方法，方法接收两个参数：TableName，ColumnFamilyDescriptor
  27.                 admin.deleteColumnFamily(tableName1, Bytes.toBytes("data1"));//删除表中名为data的列族    
  28.             
  29.             
  30.                 ColumnFamilyDescriptorBuilder buildFamily1 = ColumnFamilyDescriptorBuilder.newBuilder(Bytes.toBytes("data1"));//创建builder对象
  31.                 buildFamily1.setMinVersions(2);
  32.                 buildFamily1.setMaxVersions(5);
  33.                 buildFamily1.setInMemory(true); //默认是false
  34.                 buildFamily1.setTimeToLive(60*60*24); //以秒为单位，超过这个时间设置的就会在下一次大合并中被删除
  35.                 ColumnFamilyDescriptor family1 = buildFamily1.build();//构建Family对象
  36.                 admin.modifyColumnFamily(tableName2, family1);//调用修改方法，方法接收两个参数：TableName，ColumnFamilyDescriptor
  37.  
  38.                 admin.deleteColumnFamily(tableName2, Bytes.toBytes("data"));//删除表中名为data的列族  
  39.         
  40.             
  41.  
  42.  
  43.  
  44.  
  45.  
  46.  
  47.  
  48.         /********* End *********/
  49.     }
  50.     
  51. }

第3关：禁用表、启用表、删除表

代码文件

  1. package step3;
  2.  
  3. import java.io.IOException;
  4.  
  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.*;
  9.  
  10.  
  11. public class Task {
  12.  
  13.     /**
  14.      * 刪除表
  15.      * @param tableName 表名
  16.      * @throws Exception
  17.      */
  18.     public void deleteTable(String tableName)throws Exception{
  19.         /********* Begin *********/
  20.         Configuration conf = HBaseConfiguration.create(); //使用create()静态方法就可以得到Configuration对象
  21.         Connection conn = ConnectionFactory.createConnection(conf); //config为前文的配置对象
  22.         Admin admin = conn.getAdmin(); //使用连接对象获取Admin对象
  23.         TableName testName = TableName.valueOf(Bytes.toBytes(tableName));
  24.         admin.disableTable(testName);
  25.         admin.deleteTable(testName);
  26.     
  27.  
  28.  
  29.         /********* End *********/
  30.     }
  31.     
  32.     /**
  33.      * 创建表
  34.      * @param tableName  表名
  35.      * @param columnNames 列族的动态数组
  36.      * @throws Exception
  37.      */
  38.     public void createTable(String tableName,String... columnNames)throws Exception{
  39.         /********* Begin *********/
  40.         Configuration conf = HBaseConfiguration.create(); //使用create()静态方法就可以得到Configuration对象
  41.         Connection conn = ConnectionFactory.createConnection(conf); //config为前文的配置对象
  42.         Admin admin = conn.getAdmin(); //使用连接对象获取Admin对象
  43.  
  44.         // TableName tableName1 = TableName.valueOf(Bytes.toBytes(tableName));//定义表名
  45.         // HTableDescriptor htd = new HTableDescriptor(tableName1);//定义表对象
  46.         // for(String s: columnNames){
  47.         //     htd.addFamily(new HColumnDescriptor(Bytes.toBytes(s)));
  48.         // }
  49.  
  50.         //构建一个Test_teacher_info表
  51.         TableDescriptorBuilder test_teacher_info = TableDescriptorBuilder.newBuilder(TableName.valueOf(tableName));
  52.  
  53.         for(String s: columnNames){
  54.             ColumnFamilyDescriptor of = ColumnFamilyDescriptorBuilder.of(s);
  55.              test_teacher_info.setColumnFamily(of);
  56.         }
  57.     
  58.         //构建
  59.         TableDescriptor build = test_teacher_info.build();
  60.  
  61.         admin.createTable(build);
  62.  
  63.  
  64.  
  65.         /********* End *********/
  66.     }
  67.     
  68.     /**
  69.      * 启用表
  70.      * @param tableName 
  71.      * @throws Exception 
  72.      */
  73.     public void enableTable(String tableName) throws Exception{
  74.         /********* Begin *********/
  75.         Configuration conf = HBaseConfiguration.create(); //使用create()静态方法就可以得到Configuration对象
  76.         Connection conn = ConnectionFactory.createConnection(conf); //config为前文的配置对象
  77.         Admin admin = conn.getAdmin(); //使用连接对象获取Admin对象
  78.         TableName demoName = TableName.valueOf(Bytes.toBytes(tableName));
  79.         admin.enableTable(demoName);
  80.  
  81.  
  82.         /********* End *********/
  83.     }
  84.     
  85.     /**
  86.      * 禁用表
  87.      * @param tableName
  88.      */
  89.     public void disableTable(String tableName)throws Exception{
  90.         /********* Begin *********/
  91.         Configuration conf = HBaseConfiguration.create(); //使用create()静态方法就可以得到Configuration对象
  92.         Connection conn = ConnectionFactory.createConnection(conf); //config为前文的配置对象
  93.         Admin admin = conn.getAdmin(); //使用连接对象获取Admin对象
  94.         TableName testName = TableName.valueOf(Bytes.toBytes(tableName));
  95.         admin.disableTable(testName);
  96.  
  97.  
  98.         /********* End *********/
  99.     }
  100.     
  101. }
标签： hbase 数据库 大数据
本文转载自: https://blog.csdn.net/weixin_61657766/article/details/127362541
版权归原作者 海浪～& 所有， 如有侵权，请联系我们删除。
登录后发布评论

“头歌 HBase（相关的五个实验）”的评论:

还没有评论
关于作者
...
overfit同步小助手
文章同步
相关阅读

网络安全法-网络运行安全

使用selenium/drissionpage时如何阻止chrome自动跳转http到https

docker desktop 里部署的Open WebUI 管理员密码忘记了的处理方法

在ubuntu20.04中搭建onsite比赛运行环境

利用开源的低代码表单设计器FcDesigner高效管理和渲染复杂表单结构

Kafka学习笔记

【前端】浏览器输入url到页面呈现发生了什么？