Учебники

HBase — сбросить таблицу

Январь 29, 2019

Используя команду drop , вы можете удалить таблицу. Прежде чем бросить стол, вы должны отключить его. 

hbase(main):018:0> disable 'emp'
0 row(s) in 1.4580 seconds

hbase(main):019:0> drop 'emp'
0 row(s) in 0.3060 seconds

Убедитесь, что таблица удалена с помощью команды Существует. 

hbase(main):020:07gt; exists 'emp'
Table emp does not exist
0 row(s) in 0.0730 seconds

drop_all

Эта команда используется для удаления таблиц, соответствующих «регулярному выражению», данному в команде. Его синтаксис выглядит следующим образом: 

hbase> drop_all ‘t.*’

Примечание: перед тем, как бросить стол, вы должны отключить его.

пример

Предположим, есть таблицы с именами раджа, раджани, раджендра, раджеш и раджу. 

hbase(main):017:0> list
TABLE
raja
rajani
rajendra 
rajesh
raju
9 row(s) in 0.0270 seconds

Все эти таблицы начинаются с букв raj . Прежде всего, давайте отключим все эти таблицы с помощью команды disable_all, как показано ниже. 

hbase(main):002:0> disable_all 'raj.*'
raja
rajani
rajendra
rajesh
raju
Disable the above 5 tables (y/n)?
y
5 tables successfully disabled

Теперь вы можете удалить их все с помощью команды drop_all, как указано ниже. 

hbase(main):018:0> drop_all 'raj.*'
raja
rajani
rajendra
rajesh
raju
Drop the above 5 tables (y/n)?
y
5 tables successfully dropped

Удаление таблицы с использованием Java API

Вы можете удалить таблицу с помощью метода deleteTable () в классе HBaseAdmin . Следуйте приведенным ниже инструкциям, чтобы удалить таблицу с помощью API Java.

Шаг 1

Создайте класс HBaseAdmin. 

// creating a configuration object
Configuration conf = HBaseConfiguration.create();

// Creating HBaseAdmin object
HBaseAdmin admin = new HBaseAdmin(conf);

Шаг 2

Отключите таблицу с помощью метода disableTable () класса HBaseAdmin . 

admin.disableTable("emp1");

Шаг 3

Теперь удалите таблицу, используя метод deleteTable () класса HBaseAdmin . 

admin.deleteTable("emp12");

Ниже приведена полная Java-программа для удаления таблицы в HBase. 

import java.io.IOException;

import org.apache.hadoop.hbase.HBaseConfiguration;
import org.apache.hadoop.conf.Configuration;
import org.apache.hadoop.hbase.client.HBaseAdmin;

public class DeleteTable {

   public static void main(String[] args) throws IOException {

      // Instantiating configuration class
      Configuration conf = HBaseConfiguration.create();

      // Instantiating HBaseAdmin class
      HBaseAdmin admin = new HBaseAdmin(conf);

      // disabling table named emp
      admin.disableTable("emp12");

      // Deleting emp
      admin.deleteTable("emp12");
      System.out.println("Table deleted");
   }
}

Скомпилируйте и выполните вышеуказанную программу, как показано ниже. 

$javac DeleteTable.java
$java DeleteTable

Следующее должно быть выводом:

46
Share: