HBase Tabelle erstellen mit Java API- und Shell-Beispiel

So erstellen Sie eine Tabelle in HBase mit Java API

In HBase können Tabellen auf zwei Arten erstellt werden: über die Java API und über die HBase-Shell. Dieser Abschnitt behandelt die Java API, die es einer Anwendung ermöglicht, Tabellen zu erstellen und Daten programmatisch im Rahmen eines größeren Auftrags zu laden.

Durch Java API können wir Tabellen in HBase erstellen und auch Daten in Tabellen laden mit Java Programmierung. Die beiden Dinge, die wir hier einrichten, sind:

• Herstellen einer Verbindung mit HBase über Java API.
• Die Verwendung von Eclipse für Java Codierung, Fehlersuche und Tests.

Im Folgenden finden Sie die Schritte zum Erstellen von Tabellen in HBase durch Java API.

Schritt 1) Erstellen Sie eine Java Projekt in Eclipse

In diesem Schritt erstellen wir eine Java Projekt in Eclipse für die HBase-Verbindung mit dem Namen „HbaseConnection“.

The New Java Im folgenden Projektdialog wird die Einrichtung des Projekts „HbaseConnection“ angezeigt:

Betrachten wir den obigen Screenshot:

• Geben Sie in diesem Feld den Projektnamen ein. In unserem Fall lautet der Projektname „HbaseConnection“.
• Aktivieren Sie dieses Kontrollkästchen, um den Standardspeicherort festzulegen. Hier ist /home/hduser/work/HbaseConnection der Pfad.
• Kreuzen Sie das Kästchen an bei Java Umgebung hier. In diesem Fall JavaSE-1.7 ist der Java Ausgabe.
• Wählen Sie die Option für den Speicherort der Datei. In unserem Fall haben wir die zweite Option gewählt: „Einen separaten Ordner für Quell- und Klassendateien erstellen“.
• Klicken Sie auf die Schaltfläche „Fertigstellen“. Dadurch wird das Projekt „HbaseConnection“ erstellt. Eclipse und öffnet die Eclipse Startseite.

Schritt 2) Konfigurieren Sie den Build-Pfad in Eclipse

Auf dem Eclipse Folgen Sie diesen Schritten, um die Build-Pfad-Konfiguration zu öffnen:

Right click on project -> Select Build Path -> Configure build path

Der folgende Screenshot zeigt das Kontextmenü (Rechtsklickmenü), mit dem die Konfiguration des Build-Pfads geöffnet werden kann:

Aus dem obigen Screenshot:

• Klicken Sie mit der rechten Maustaste auf ein Projekt.
• Build-Pfad auswählen.
• Wählen Sie „Buildpfad konfigurieren“.

Nach dem Klicken auf „Buildpfad konfigurieren“ öffnet sich ein weiteres Fenster, wie im folgenden Screenshot dargestellt. Auf der Registerkarte „Bibliotheken“ werden die HBase- und Hadoop-JAR-Dateien zum Projekt hinzugefügt:

In diesem Schritt fügen wir die entsprechenden HBase-JAR-Dateien hinzu. Java Das Projekt sieht aus wie im Screenshot dargestellt.

• Wichtige hinzuzufügende JAR-Dateien: hbase-0.94.8.jar und hadoop-core-1.1.2.jar.
• Wechseln Sie zum Reiter „Bibliotheken“.
• Drücken Sie die Option "Externe JAR-Dateien hinzufügen".
• Wählen Sie die erforderlichen wichtigen JAR-Dateien aus.
• Drücken Sie die Schaltfläche „Fertigstellen“, um diese Dateien zum „src“-Verzeichnis hinzuzufügen. Java Projekt im Rahmen der Bibliotheken.

Nach dem Hinzufügen der JAR-Dateien erscheinen sie im Projektverzeichnis „src“, wie unten dargestellt:

Alle JAR-Dateien, die zu diesem Projekt gehören, sind nun für die Verwendung mit dem Hadoop-Ökosystem bereit.

Schritt 3) Stellen Sie die HBase-Verbindung her

In diesem Schritt wird mithilfe von HBaseConnection.java die HBase-Verbindung hergestellt. Java Codierung.

Auf dem Eclipse oberstes Menü, ausführen Java Programm wie unten gezeigt: Ausführen -> Ausführen als -> Java Anwendung. Das folgende Menü zeigt den Programmstart an:

• Wählen Sie Ausführen.
• Wählen Sie „Ausführen als“ Java Anwendung.
• Dieser Code stellt eine Verbindung zu HBase her über Java API.
• Nach Ausführung dieses Codes wird in HBase die Tabelle „guru99“ mit zwei Spaltenfamilien namens „education“ und „projects“ erstellt. Aktuell existiert in HBase lediglich ein leeres Schema.

Der folgende Codeausschnitt hebt die HTable hervor.Descriptoder und addFamily-Aufrufe, die das Tabellenschema erstellen:

Aus dem obigen Screenshot geht hervor, dass wir folgende Funktionen ausführen:

• Verwenden von HTableDescriptOder wir können die Tabelle „guru99“ in HBase erstellen.
• Mit der Methode addFamily fügen wir der Tabelle „guru99“ die Spaltenfamilien „education“ und „projects“ hinzu.

Der folgende Code stellt eine Verbindung zu HBase her und erstellt die Tabelle „guru99“ mit zwei Spaltenfamilien. Fügen Sie diesen Code unterhalb der Datei HBaseConnection.java ein:

// Place this code inside Hbase connection
import java.io.IOException;
import org.apache.hadoop.conf.Configuration;
import org.apache.hadoop.hbase.HBaseConfiguration;
import org.apache.hadoop.hbase.HColumnDescriptor;
import org.apache.hadoop.hbase.HTableDescriptor;
Import org.apache.hadoop.hbase.client.HBaseAdmin;

public class HBaseConnection
{
    public static void main(String[] args) throws IOException
    {
	HBaseConfigurationhc = new HBaseConfiguration(new Configuration());
	HTableDescriptorht = new HTableDescriptor("guru99");

	ht.addFamily( new HColumnDescriptor("education"));
	ht.addFamily( new HColumnDescriptor("projects"));
	System.out.println( "connecting" );
	HBaseAdminhba = new HBaseAdmin( hc );

	System.out.println( "Creating Table" );
	hba.createTable( ht );
	System.out.println("Done......");
    }
}

Dies ist der erforderliche Code, den Sie in HBaseConnection.java einfügen müssen, bevor Sie das Programm ausführen. Java

Nach dem Ausführen dieses Programms wird eine Verbindung zu HBase hergestellt und anschließend eine Tabelle mit Spaltennamen erstellt.

• Der Tabellenname lautet „guru99“.
• Die Spaltenfamilien sind „Bildung“ und „Projekte“.

Schritt 4) Überprüfen Sie die erstellte Tabelle in HBase

Wir können mithilfe des Befehls „list“ im HBase-Shell-Modus überprüfen, ob die Tabelle „guru99“ in HBase mit zwei Spaltenfamilien erstellt wurde. Der Befehl „list“ liefert Informationen über alle in HBase erstellten Tabellen.

Die Ausführung des Befehls „list“ in der HBase-Shell bestätigt die neue Tabelle, wie unten dargestellt:

• Code Überprüfen Sie dies in der HBase-Shell durch Ausführen des Befehls „list“.
• Wenn wir den Befehl „list“ ausführen, werden die in HBase erstellten Tabellen angezeigt. In unserem Fall sehen wir, dass die Tabelle „guru99“ erstellt wurde.

HBase Tabelle mit Shell erstellen

Neben dem Java Über die API können Sie direkt in der HBase-Shell eine Tabelle erstellen. Dies ist der schnellste Weg, eine Tabelle für schnelle Tests einzurichten. Die Syntax zum Erstellen einer Tabelle in HBase über die Shell lautet:

Syntax: create <tablename>, <columnfamilyname>

Beispiel:-

hbase(main):001:0> create 'education' ,'guru99'
0 rows(s) in 0.312 seconds
=>Hbase::Table – education

Das obige Beispiel erklärt, wie man in HBase eine Tabelle mit dem angegebenen Namen gemäß den Spezifikationen für jede Spaltenfamilie erstellt. Zusätzlich können wir ihr auch Tabellenattribute übergeben.

create 'guru99', {NAME=>'Edu', VERSIONS=>213423443}

Der Block {NAME=>'Edu', VERSIONS=>…} definiert hier eine Spaltenfamilie namens „Edu“ und die Anzahl der gespeicherten Zellversionen. Die hohe Zahl dient nur der Veranschaulichung; in der Praxis ist VERSIONS ein kleiner Wert wie 3 oder 5.

HBase-Tabellen auflisten, beschreiben und überprüfen

Das Erstellen einer Tabelle ist nur der erste Schritt bei der Tabellenverwaltung in HBase. Sobald die Tabelle „guru99“ existiert, können Sie sie mit einigen allgemeinen Befehlen überprüfen und ihren Zustand bestätigen, bevor Sie Daten lesen, schreiben oder ändern. Sie können alle diese Befehle über die Benutzeroberfläche ausführen. HBase-Shell.

Der Befehl „list“ gibt alle Benutzertabellen in HBase zurück:

hbase> list

Der Befehl „describe“ zeigt die Struktur einer Tabelle an, einschließlich ihrer Spaltenfamilien und ob sie aktuell aktiviert ist:

hbase> describe 'guru99'

Der Befehl exists prüft, ob eine Tabelle vorhanden ist, und is_enabled meldet, ob die Tabelle Schreibvorgänge akzeptieren kann:

hbase> exists 'guru99'
hbase> is_enabled 'guru99'

Diese schreibgeschützten Prüfungen können jederzeit sicher ausgeführt werden. Sie sind der schnellste Weg, um zu bestätigen, dass eine Tabelle korrekt erstellt wurde und um ihre Spaltenfamilien vor dem Laden von Daten zu überprüfen.

Ändern einer HBase-Tabelle

Das Schema einer HBase-Tabelle ist nach der Erstellung nicht unveränderlich. Der Befehl `alter` ändert die Spaltenfamilien und Tabellenattribute einer Tabelle, ohne sie neu zu erstellen. Je nach Ihrer HBase-Version müssen Sie die Tabelle möglicherweise zuerst deaktivieren, dann `alter` ausführen und sie anschließend wieder aktivieren.

So fügen Sie der Tabelle „guru99“ eine neue Spaltenfamilie hinzu:

hbase> alter 'guru99', {NAME => 'contact'}

So legen Sie fest, wie viele Versionen eine Spaltenfamilie speichert:

hbase> alter 'guru99', NAME => 'education', VERSIONS => 5

So löschen Sie eine Spaltenfamilie aus der Tabelle:

hbase> alter 'guru99', {NAME => 'contact', METHOD => 'delete'}

Sie können auch Tabellenattribute ändern. Beispielsweise können Sie die Tabelle als schreibgeschützt markieren oder die maximale Regionsdateigröße auf 128 MB festlegen:

hbase> alter 'guru99', READONLY
hbase> alter 'guru99', MAX_FILESIZE => '134217728'

Da der Befehl ALTER das Schema überschreibt, sollten Änderungen sorgfältig an einer Produktionstabelle geplant und das Ergebnis anschließend mit dem Befehl DESCRIBE bestätigt werden.

HBase-Tabellen deaktivieren, aktivieren und löschen

Um eine Tabelle zu entfernen oder bestimmte Änderungen vorzunehmen, müssen Sie diese in HBase zunächst deaktivieren. Durch die Deaktivierung wird die Tabelle offline genommen, sodass kein Client mehr darauf zugreifen kann. Dadurch werden strukturelle Änderungen sicher.

Eine Tabelle deaktivieren und ihren Status mit is_disabled überprüfen:

hbase> disable 'guru99'
hbase> is_disabled 'guru99'

Aktivieren Sie die Tabelle erneut, um Lese- und Schreibvorgänge fortzusetzen:

hbase> enable 'guru99'

Eine Tabelle muss deaktiviert werden, bevor sie gelöscht werden kann. Löschenping Löscht die Tabelle und alle darin enthaltenen Daten endgültig, daher mit Vorsicht verwenden:

hbase> disable 'guru99'
hbase> drop 'guru99'

Um mehrere Tabellen gleichzeitig zu entfernen, löscht `drop_all` alle Tabellen, deren Name einem regulären Ausdruck entspricht. Zusammen decken `create`, `alter`, `disable`, `enable` und `drop` den gesamten Lebenszyklus einer Tabelle ab. Datenverarbeitung in HBase-Tabellen.

Häufig gestellte Fragen