HBase Vytvořit tabulku s příkladem

Obsah:

Anonim

V HBase můžeme vytvořit operace s tabulkou dvěma způsoby

  • Příkaz prostředí
  • JAVA API

Naučíme se používat obě k vytváření tabulek.

  • HBase Vytvořit tabulku s Java API
  • HBase Vytvořit tabulku s Shell

HBase vytvoří tabulku s Java API

V této části provedeme některé operace pomocí Java kódování prostřednictvím Java API.

Prostřednictvím Java API můžeme vytvářet tabulky v HBase a také načítat data do tabulek pomocí kódování Java.

  • Navázání spojení s HBase prostřednictvím Java API
  • Používání Eclipse pro kódování Java, ladění a testování

Navazování připojení prostřednictvím Java API:

Následující kroky nás provedou vývojem kódu Java pro připojení HBase prostřednictvím rozhraní Java API.

Krok 1) V tomto kroku vytvoříme projekt Java v zatmění pro připojení HBase.

Vytvoření nového názvu projektu "HbaseConnection" v zatmění.

Pro vytvoření nebo vytvoření programu souvisejícího s projektem Java

Pokud sledujeme výše uvedený snímek obrazovky.

  1. Do tohoto pole uveďte název projektu. V našem případě máme název projektu „HbaseConnection“
  2. Zaškrtněte toto políčko, chcete-li uložit výchozí umístění. V tomto / home / hduser / work / HbaseConnection je cesta
  3. Zde zaškrtněte políčko prostředí Java. V tomto prostředí JavaSE-1.7 je vydání Java
  4. Vyberte možnost, kam chcete soubor uložit. V našem případě jsme vybrali možnost druhá „Vytvořit samostatnou složku pro zdroje a soubory tříd“
  5. Klikněte na tlačítko Dokončit.
  • Když kliknete na tlačítko Dokončit, vytvoří se v zatmění projekt „HbaseConnection“
  • Po kliknutí na tlačítko Dokončit se přímo dostane na domovskou stránku zatmění.

Krok 2) Na domovské stránce zatmění postupujte podle následujících kroků

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

Z výše uvedeného snímku obrazovky

  1. Klikněte pravým tlačítkem na projekt
  2. Vyberte cestu sestavení
  3. Vyberte konfiguraci cesty sestavení

Po kliknutí na Konfigurovat cestu sestavení se otevře další okno, jak je znázorněno na následujícím snímku obrazovky

V tomto kroku přidáme do projektu Java relevantní sklenice HBase, jak je znázorněno na snímku obrazovky.

  • Důležité sklenice, které mají být přidány hbase-0.94.8.jar, hadoop-core-1.1.2.jar
  • Klikněte na tlačítko Dokončit

  1. Přijďte do knihoven
  2. Stiskněte možnost - Přidat externí nádoby
  3. Vyberte požadované důležité sklenice
  4. Stisknutím tlačítka Dokončit přidáte tyto soubory do „src“ java projektu v knihovnách

Po přidání těchto sklenic se zobrazí pod umístěním projektu „src“. Všechny soubory Jar, které spadají pod projekt, jsou nyní připraveny k použití s ​​ekosystémem Hadoop.

Krok 3) V tomto kroku pomocí HBaseConnection.java bude připojení HBase navázáno prostřednictvím Java Coding

  • V horní nabídce Eclipse spusťte program Java, jak je znázorněno níže

    Spustit -> Spustit jako -> Java aplikace

  1. Vyberte Spustit
  2. Vyberte Spustit jako Java aplikaci
  • Tento kód vytvoří spojení s HBase prostřednictvím Java API
  • Po spuštění tohoto kódu bude v HBase vytvořena tabulka „guru99“ se dvěma rodinami sloupců s názvem „education“ a „projects“. V současné době je prázdné schéma vytvořeno pouze v HBase.

Z výše uvedeného snímku obrazovky provádíme následující funkce.

  1. Pomocí HTableDescriptor můžeme vytvořit tabulku "guru99" v HBase
  2. Pomocí metody addFamily přidáme do tabulky „guru99“ „vzdělávání“ a „projekty“ jako názvy sloupců.

Níže uvedené kódování bude

  • Navažte spojení s HBase a
  • Vytvořte tabulku "guru99" se dvěma sloupci

Kód umístěn pod dokumentem 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… ");}}

Toto je požadovaný kód, který musíte umístit do HBaseConnection.java a musíte spustit program Java

Po spuštění tohoto programu se chystá navázat spojení s HBase a následně vytvoří tabulku s názvy sloupců.

  • Název tabulky je „guru99“
  • Názvy sloupců jsou „vzdělávání“ a „projekty“

Krok 4) Můžeme zkontrolovat, zda je tabulka „guru99“ vytvořena se dvěma sloupci v HBase nebo ne, pomocí režimu prostředí HBase s příkazem „list“.

Příkaz "list" poskytuje informace o všech tabulkách vytvořených v HBase.

Na této obrazovce budeme dělat

  • Kontrola kódu v prostředí HBase spuštěním příkazu "list".
  • Pokud spustíme příkaz "list", zobrazí se tabulka vytvořená v HBase, jak je uvedeno níže. V našem případě vidíme, že je vytvořena tabulka „guru99“

HBase Vytvořit tabulku s Shell

Syntaxe pro vytvoření tabulky je

Syntax: create 
, 

Příklad:-

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

Výše uvedený příklad vysvětluje, jak vytvořit tabulku v HBase se zadaným názvem zadaným podle slovníku nebo specifikací podle rodiny sloupců. Kromě toho do něj můžeme předat také některé atributy rozsahu tabulky.

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

Souhrn:

HBase je sloupcově orientovaná databáze NoSQL pro ukládání velkého množství dat nad ekosystémem Hadoop. Zpracování tabulek v HBase je velmi zásadní věc, protože všechny důležité funkce, jako jsou datové operace, vylepšení dat a modelování dat, můžeme provádět pouze pomocí tabulek v HBase. Tabulky plní následující funkce 1) Vytváření tabulek s názvy sloupců a řádky 2) Vkládání hodnot do tabulek 3) Načítání hodnot z tabulek