返回介绍
文江博客 开发文档 HBase 教程 文章详情

HBase 表描述和更改

发布于 2024-06-23 16:37:45 字数 21232 浏览 0 评论 0 收藏 0

描述

describe返回表的描述。其语法如下：

  1. hbase> describe 'table name'

下面给出的是emp表上describe命令的输出。

  1. hbase(main):006:0> describe 'emp'
  2.   Table emp is ENABLED  emp
  3. COLUMN FAMILIES DESCRIPTION
  4. {NAME => 'personal data', BLOOMFILTER => 'ROW', IN_MEMORY => 'false', VERSIONS => '1', KEEP_DELETED_CELLS => 'FA
  5. LSE', DATA_BLOCK_ENCODING => 'NONE', COMPRESSION => 'NONE', TTL => 'FOREVER', MIN_VERSIONS => '0', BLOCKCACHE =>
  6.  'true', BLOCKSIZE => '65536', REPLICATION_SCOPE => '0'}
  7. {NAME => 'professional data', BLOOMFILTER => 'ROW', IN_MEMORY => 'false', VERSIONS => '1', KEEP_DELETED_CELLS =>
  8.  'FALSE', DATA_BLOCK_ENCODING => 'NONE', COMPRESSION => 'NONE', TTL => 'FOREVER', MIN_VERSIONS => '0', BLOCKCACH
  9. E => 'true', BLOCKSIZE => '65536', REPLICATION_SCOPE => '0'}
  11. 2 row(s)
  12. Quota is disabled
  13. Took 7.8766 seconds

更改

alter是用于更改现有表的命令。使用此命令，您可以更改列系列的最大单元数，设置和删除表范围运算符，以及从表中删除列系列。

更改列族的最大单元数

下面给出的是更改列族的最大单元数的语法。

  1. hbase> alter 't1', NAME => 'f1', VERSIONS => 5

在以下示例中，最大单元数设置为5。

  1. hbase(main):003:0> alter 'emp', NAME => 'personal data', VERSIONS => 5
  2. Updating all regions with the new schema...
  3. 0/1 regions updated.
  4. 1/1 regions updated.
  5. Done.
  6. 0 row(s) in 2.3050 seconds

表范围运算符

使用alter可以设置和删除表范围运算符，例如MAX_FILESIZE，READONLY，MEMSTORE_FLUSHSIZE，DEFERRED_LOG_FLUSH等。

设置只读

下面给出的是使表只读的语法。

  1. hbase>alter 't1', READONLY(option)

在以下示例中，我们使emp表为只读。

  1. hbase(main):006:0> alter 'emp', READONLY
  2. Updating all regions with the new schema...
  3. 0/1 regions updated.
  4. 1/1 regions updated.
  5. Done.
  6. 0 row(s) in 2.2140 seconds

删除表范围运算符

我们还可以删除表范围运算符。下面给出的是从emp表中删除MAX_FILESIZE的语法。

  1. hbase> alter 't1', METHOD => 'table_att_unset', NAME => 'MAX_FILESIZE'

删除列族

使用alter，还可以删除列族。下面给出的是使用alter删除列族的语法。

  1. hbase> alter 'table name ', 'delete' => 'column family'

以下是从emp表中删除列族的示例。
假设在HBase中有一个名为employee的表。它包含以下数据：

  1. hbase(main):006:0> scan 'employee'
  3.    ROW                   COLUMN+CELL
  5. row1 column = personal:city, timestamp = 1418193767, value = hyderabad
  7. row1 column = personal:name, timestamp = 1418193806767, value = raju
  9. row1 column = professional:designation, timestamp = 1418193767, value = manager
  11. row1 column = professional:salary, timestamp = 1418193806767, value = 50000
  13. 1 row(s) in 0.0160 seconds

现在，让我们使用alter命令删除名为professional的列族。

  1. hbase(main):007:0> alter 'employee','delete'⇒'professional'
  2. Updating all regions with the new schema...
  3. 0/1 regions updated.
  4. 1/1 regions updated.
  5. Done.
  6. 0 row(s) in 2.2380 seconds

现在，更改后验证表中的数据。观察列系列“专业”已不再存在，因为我们已将其删除。

  1. hbase(main):003:0> scan 'employee'
  2.    ROW             COLUMN + CELL
  3. row1 column = personal:city, timestamp = 14181936767, value = hyderabad
  5. row1 column = personal:name, timestamp = 1418193806767, value = raju
  7. 1 row(s) in 0.0830 seconds

使用Java API添加列族

您可以使用HBAseAdmin类的方法addColumn()把列族添加到表。请按照下面给出的步骤将列族添加到表中。

第1步

获得Admin类。

  1. // Instantiating configuration class
  2. Configuration config = HBaseConfiguration.create();
  3. Connection connection = ConnectionFactory.createConnection(config);
  4. // Instantiating Admin class
  5. Admin admin = null;
  6. admin = connection.getAdmin();

第2步

上述addColumn()方法需要2个参数，一个是表名，一个是HColumnDescriptor类。因此，需要实例化HColumnDescriptor类。HColumnDescriptor的构造函数又需要添加列族名称。在这里，我们将一个名为contactDetails的列族添加到现有的emp表中。

  1. // Instantiating columnDescriptor object
  3. HColumnDescriptor columnDescriptor = new HColumnDescriptor("contactDetails");

第3步

使用addColumn方法添加列系列。将表名和HColumnDescriptor类对象作为参数传递给此方法。

  1. // Adding column family
  2. admin.addColumn(TableName.valueOf("emp"), columnDescriptor);

下面给出的是将列族添加到现有表的完整程序。

  1. import java.io.IOException;
  3. import org.apache.hadoop.hbase.HBaseConfiguration;
  4. import org.apache.hadoop.hbase.HColumnDescriptor;
  5. import org.apache.hadoop.hbase.TableName;
  6. import org.apache.hadoop.hbase.client.Connection;
  7. import org.apache.hadoop.hbase.client.ConnectionFactory;
  8. import org.apache.hadoop.hbase.client.Admin;
  10. import org.apache.hadoop.conf.Configuration;
  12. @SuppressWarnings("deprecation")
  14. public class AddColoumn{
  16.   public static void main(String[] args) throws IOException {
  17.       try {
  18.          // Instantiating configuration class
  19.          Configuration config = HBaseConfiguration.create();
  20.          Connection connection = ConnectionFactory.createConnection(config);
  21.          // Instantiating Admin class
  22.          Admin admin = null;
  23.          admin = connection.getAdmin();
  25.          // Instantiating columnDescriptor class
  27.          HColumnDescriptor columnDescriptor = new HColumnDescriptor("contactDetails");
  29.          // Adding column family
  30.          admin.addColumn(TableName.valueOf("emp"), columnDescriptor);
  31.          System.out.println("coloumn added");
  33.       } catch (Exception e) {
  34.          System.out.println(e.getMessage());
  35.       }
  36.    }
  37. }
  38. 编译并执行上述程序，如下所示。
  40. $javac AddColumn.java
  41. $java AddColumn
  42. 如果一切顺利，它将产生以下输出：
  44. column added
  45. 使用Java API删除列族
  46. 您可以使用该方法从表中删除列族deleteColumn（）的HBAseAdmin类。请按照下面给出的步骤将列族添加到表中。
  47. 第1步 Admin类。
  49. // Instantiating configuration class
  50. Configuration config = HBaseConfiguration.create();
  51. Connection connection = ConnectionFactory.createConnection(config);
  52. // Instantiating Admin class
  53. Admin admin = null;
  54. admin = connection.getAdmin(); 
  55. 第2步 - 使用deleteColumn（）方法删除列族。将表名和列族名作为参数传递给此方法。
  57. // Deleting column family
  58. String col = "contactDetails";
  59. // delete column family
  60. admin.deleteColumn(TableName.valueOf("emp"), col.getBytes());
  61. 下面给出的是从现有表中删除列族的完整程序。
  63. import java.io.IOException;
  65. import org.apache.hadoop.hbase.HBaseConfiguration; 
  66. import org.apache.hadoop.hbase.TableName;
  67. import org.apache.hadoop.hbase.client.Connection;
  68. import org.apache.hadoop.hbase.client.ConnectionFactory;
  69. import org.apache.hadoop.hbase.client.Admin;
  71. import org.apache.hadoop.conf.Configuration;
  73. @SuppressWarnings("deprecation")
  75. public class DeleteColoumn{
  77.    public static void main(String args[]) throws MasterNotRunningException, IOException{
  79.       try {
  80.          // Instantiating configuration class
  81.          Configuration config = HBaseConfiguration.create();
  82.          Connection connection = ConnectionFactory.createConnection(config);
  83.          // Instantiating Admin class
  84.          Admin admin = null;
  85.          admin = connection.getAdmin();
  87.          String col = "contactDetails";
  88.          // delete column family
  89.          admin.deleteColumn(TableName.valueOf("emp"), col.getBytes());
  90.          System.out.println("coloumn deleted");
  92.       } catch (Exception e) {
  93.          System.out.println(e.getMessage());
  94.       }
  95.    }
  96. }

编译并执行上述程序，如下所示。

  1. $javac DeleteColumn.java
  2. $java DeleteColumn

以下应该是输出：

  1. column deleted

使用Java API删除列族

您可以使用HBAseAdmin类的deleteColumn()方法从表中删除列族的。请按照下面给出的步骤将列族添加到表中。

第1步

获取Admin类。

  1. // Instantiating configuration class
  2. Configuration config = HBaseConfiguration.create();
  3. Connection connection = ConnectionFactory.createConnection(config);
  4. // Instantiating Admin class
  5. Admin admin = null;
  6. admin = connection.getAdmin();

第2步

使用deleteColumn()方法删除列族。将表名和列族名作为参数传递给此方法。

  1. // Deleting column family
  2. String col = "contactDetails";
  3. // delete column family
  4. admin.deleteColumn(TableName.valueOf("emp"), col.getBytes());

下面给出的是从现有表中删除列族的完整程序。

  1. import java.io.IOException;
  3. import org.apache.hadoop.hbase.HBaseConfiguration; 
  4. import org.apache.hadoop.hbase.TableName;
  5. import org.apache.hadoop.hbase.client.Connection;
  6. import org.apache.hadoop.hbase.client.ConnectionFactory;
  7. import org.apache.hadoop.hbase.client.Admin;
  9. import org.apache.hadoop.conf.Configuration;
  11. @SuppressWarnings("deprecation")
  13. public class DeleteColoumn{
  15.    public static void main(String args[]) throws MasterNotRunningException, IOException{
  17.       try {
  18.          // Instantiating configuration class
  19.          Configuration config = HBaseConfiguration.create();
  20.          Connection connection = ConnectionFactory.createConnection(config);
  21.          // Instantiating Admin class
  22.          Admin admin = null;
  23.          admin = connection.getAdmin();
  25.          String col = "contactDetails";
  26.          // delete column family
  27.          admin.deleteColumn(TableName.valueOf("emp"), col.getBytes());
  28.          System.out.println("coloumn deleted");
  30.       } catch (Exception e) {
  31.          System.out.println(e.getMessage());
  32.       }
  33.    }
  34. }

编译并执行上述程序，如下所示。

  1. $javac DeleteColumn.java
  2. $java DeleteColumn

以下应该是输出：

  1. column deleted

如果你对这篇内容有疑问，欢迎到本站社区发帖提问 参与讨论，获取更多帮助，或者扫码二维码加入 Web 技术交流群。

扫码二维码加入Web技术交流群

发布评论

需要 登录 才能够评论， 你可以免费 注册 一个本站的账号。
列表为空，暂无数据
    我们使用 Cookies 和其他技术来定制您的体验包括您的登录状态等。通过阅读我们的 隐私政策 了解更多相关信息。 单击 接受 或继续使用网站，即表示您同意使用 Cookies 和您的相关数据。
    原文