HBase Utwórz tabelę z przykładem

Spisie treści:

Anonim

W HBase możemy tworzyć operacje na tabelach na dwa sposoby

  • Polecenie powłoki
  • JAVA API

Nauczymy się używać obu do tworzenia tabel.

  • HBase Utwórz tabelę za pomocą interfejsu API języka Java
  • HBase Utwórz tabelę za pomocą powłoki

HBase utwórz tabelę za pomocą Java API

W tej sekcji zamierzamy wykonać niektóre operacje przy użyciu kodowania w języku Java za pośrednictwem interfejsu API języka Java.

Dzięki Java API możemy tworzyć tabele w HBase, a także ładować dane do tabel za pomocą kodowania Java.

  • Nawiązanie połączenia z HBase przez Java API
  • Używanie Eclipse do kodowania, debugowania i testowania w Javie

Nawiązanie połączenia przez Java API:

Poniższe kroki prowadzą nas do opracowania kodu Java do łączenia HBase za pośrednictwem Java API.

Krok 1) W tym kroku utworzymy projekt Java w Eclipse dla połączenia HBase.

Utworzenie nowej nazwy projektu „HbaseConnection” w eclipse.

Do tworzenia lub tworzenia programów związanych z projektami Java

Jeśli obserwujemy powyższy zrzut ekranu.

  1. W tym polu podaj nazwę projektu. W naszym przypadku mamy nazwę projektu „HbaseConnection”
  2. Zaznacz to pole, aby zapisać domyślną lokalizację. W tym katalogu / home / hduser / work / HbaseConnection znajduje się ścieżka
  3. Zaznacz tutaj pole dla środowiska Java. W tym JavaSE-1.7 jest wydaniem Java
  4. Wybierz opcję, w której chcesz zapisać plik. W naszym przypadku wybraliśmy drugą opcję „Utwórz osobny folder dla źródeł i plików klas”
  5. Kliknij przycisk Zakończ.
  • Kliknięcie przycisku Zakończ spowoduje utworzenie projektu „HbaseConnection” w zaćmieniu
  • Przejdzie bezpośrednio do strony głównej zaćmienia po kliknięciu przycisku Zakończ.

Krok 2) Na stronie głównej eclipse wykonaj następujące kroki

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

Z powyższego zrzutu ekranu

  1. Kliknij projekt prawym przyciskiem myszy
  2. Wybierz ścieżkę budowania
  3. Wybierz opcję Skonfiguruj ścieżkę kompilacji

Po kliknięciu Konfiguruj ścieżkę kompilacji, otworzy się kolejne okno, jak pokazano na poniższym zrzucie ekranu

W tym kroku dodamy odpowiednie pliki JAR HBase do projektu java, jak pokazano na zrzucie ekranu.

  • Ważne słoiki do dodania hbase-0.94.8.jar, hadoop-core-1.1.2.jar
  • Kliknij przycisk Zakończ

  1. Przyjdź do bibliotek
  2. Opcja prasy - Dodaj zewnętrzne słoiki
  3. Wybierz wymagane ważne słoiki
  4. Naciśnij przycisk Zakończ, aby dodać te pliki do „źródła” projektu java w bibliotekach

Po dodaniu tych plików, pojawi się w lokalizacji projektu „src”. Wszystkie pliki Jar objęte projektem są teraz gotowe do użycia w ekosystemie Hadoop.

Krok 3) Na tym etapie przy użyciu HBaseConnection.java połączenie HBase zostanie nawiązane za pomocą Java Coding

  • W górnym menu Eclipse uruchom program Java, jak pokazano poniżej

    Uruchom -> Uruchom jako -> Aplikacja Java

  1. Wybierz Uruchom
  2. Wybierz opcję Uruchom jako aplikację Java
  • Ten kod ustanowi połączenie z HBase za pośrednictwem Java API
  • Po uruchomieniu tego kodu w HBase zostanie utworzona tabela „guru99” z dwiema rodzinami kolumn o nazwach „edukacja” i „projekty”. Obecnie pusty schemat jest tworzony tylko w HBase.

Na powyższym zrzucie ekranu wykonujemy następujące funkcje.

  1. Używając HTableDescriptor możemy stworzyć tabelę „guru99” w HBase
  2. Używając metody addFamily, dodamy „edukacja” i „projekty” jako nazwy kolumn do tabeli „guru99”.

Poniższe kodowanie będzie

  • Nawiąż połączenie z HBase i
  • Utwórz tabelę „guru99” z dwiema kolumnami

Kod umieszczony w dokumencie HBaseConnection_Java 

// Place this code inside Hbase connectionimport 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… ");}}

Jest to wymagany kod, który musisz umieścić w HBaseConnection.java i uruchomić program java

Po uruchomieniu tego programu nawiąże połączenie z HBase iz kolei utworzy tabelę z nazwami kolumn.

  • Nazwa tabeli to „guru99”
  • Nazwy kolumn to „edukacja” i „projekty”

Krok 4) Możemy sprawdzić, czy tabela „guru99” jest utworzona z dwiema kolumnami w HBase, czy nie, używając trybu powłoki HBase z poleceniem „list”.

Polecenie „list” zawiera informacje o wszystkich tabelach utworzonych w bazie danych HBase.

Na tym ekranie zrobimy

  • Sprawdzanie kodu w powłoce HBase przez wykonanie polecenia „list”.
  • Jeśli uruchomimy polecenie „list”, wyświetli tabelę utworzoną w HBase, jak poniżej. W naszym przypadku widzimy, że tworzona jest tabela „guru99”

HBase Utwórz tabelę za pomocą powłoki

Składnia tworzenia tabeli to

Syntax: create 
,

Przykład:-

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

Powyższy przykład wyjaśnia, jak utworzyć tabelę w HBase o określonej nazwie podanej zgodnie ze słownikiem lub specyfikacjami zgodnie z rodziną kolumn. Oprócz tego możemy również przekazać do niego niektóre atrybuty zakresu tabeli.

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

Podsumowanie:

HBase to zorientowana na kolumny baza danych NoSQL do przechowywania dużej ilości danych w ekosystemie Hadoop. Obsługa tabel w HBase jest bardzo kluczowa, ponieważ wszystkie ważne funkcjonalności, takie jak operacje na danych, ulepszenia danych i modelowanie danych, możemy wykonać tylko za pomocą tabel w HBase. Tabele pełnią następujące funkcje 1) Tworzenie tabel z nazwami kolumn i wierszami 2) Wstawianie wartości do tabel 3) Pobieranie wartości z tabel