V HBase môžeme operácie s tabuľkami vytvárať dvoma spôsobmi
- Príkaz shell
- JAVA API
Naučíme sa používať obidve pri vytváraní tabuliek.
- HBase Vytvorenie tabuľky s Java API
- HBase Vytvorenie tabuľky pomocou aplikácie Shell
HBase vytvorí tabuľku s Java API
V tejto časti budeme vykonávať niektoré operácie pomocou Java kódovania cez Java API.
Prostredníctvom Java API môžeme vytvárať tabuľky v HBase a tiež načítať údaje do tabuliek pomocou kódovania Java.
- Nadviazanie spojenia s HBase prostredníctvom rozhrania Java API
- Používanie Eclipse na kódovanie Java, ladenie a testovanie
Nadviazanie spojenia prostredníctvom Java API:
Nasledujúce kroky nás prevedú vývojom kódu Java na pripojenie HBase cez rozhranie Java API.
Krok 1) V tomto kroku vytvoríme projekt Java v zatmení pre pripojenie HBase.
Vytvorenie nového názvu projektu "HbaseConnection" v zatmení.
Pre vytvorenie alebo vytvorenie programu súvisiaceho s projektom Java
Ak sledujeme snímku obrazovky vyššie.
- Do tohto poľa zadajte názov projektu. V našom prípade máme názov projektu „HbaseConnection“
- Začiarknite toto políčko, ak chcete uložiť predvolené umiestnenie. V tomto / home / hduser / work / HbaseConnection je cesta
- Tu začiarknite políčko pre prostredie Java. V tomto JavaSE-1.7 je vydanie Java
- Vyberte možnosť, kam chcete súbor uložiť. V našom prípade sme vybrali možnosť druhá „Vytvoriť samostatný priečinok pre zdroje a súbory triedy“
- Kliknite na tlačidlo Dokončiť.
- Keď kliknete na tlačidlo Dokončiť, vytvorí sa v zatmení projekt „HbaseConnection“
- Po kliknutí na tlačidlo Dokončiť sa priamo zobrazí domovská stránka zatmenia.
Krok 2) Na domovskej stránke zatmenia postupujte podľa nasledujúcich krokov
Right click on project -> Select Build Path -> Configure build path
Z obrazovky vyššie
- Kliknite pravým tlačidlom myši na projekt
- Vyberte cestu zostavenia
- Vyberte konfigurovať cestu zostavenia
Po kliknutí na Konfigurovať cestu zostavenia sa otvorí ďalšie okno, ako je znázornené na obrázku nižšie
V tomto kroku pridáme príslušné nádoby HBase do projektu Java, ako je znázornené na snímke obrazovky.
- Dôležité nádoby, ktoré sa majú pridať hbase-0.94.8.jar, hadoop-core-1.1.2.jar
- Kliknite na tlačidlo Dokončiť
- Príďte do knižníc
- Stlačte možnosť - Pridať externé poháre
- Vyberte požadované dôležité poháre
- Stlačením tlačidla Dokončiť pridáte tieto súbory do súboru „src“ java projektu v knižniciach
Po pridaní týchto nádob sa zobrazí pod umiestnením projektu „src“. Všetky súbory Jar, ktoré spadajú pod projekt, sú teraz pripravené na použitie s ekosystémom Hadoop.
Krok 3) V tomto kroku pomocou súboru HBaseConnection.java by sa pripojenie HBase nadviazalo prostredníctvom Java Coding
- V hornom menu programu Eclipse vykonajte program Java, ako je to zobrazené nižšie
Spustiť -> Spustiť ako -> Aplikácia Java
- Vyberte Spustiť
- Vyberte možnosť Spustiť ako aplikáciu Java
- Tento kód vytvorí spojenie s HBase prostredníctvom Java API
- Po spustení tohto kódu sa v HBase vytvorí tabuľka „guru99“ s dvoma rodinami stĺpcov s názvom „vzdelávanie“ a „projekty“. Prázdna schéma je v súčasnosti vytvorená iba v HBase.
Na snímke obrazovky vyššie vykonávame nasledujúce funkcie.
- Pomocou HTableDescriptor môžeme vytvoriť tabuľku "guru99" v HBase
- Použitím metódy addFamily pridáme do tabuľky „guru99“ ako názvy stĺpcov „vzdelávanie“ a „projekty“.
Nižšie uvedené kódovanie sa chystá
- Nadviazať spojenie s HBase a
- Vytvorte tabuľku "guru99" s dvoma stĺpcami
Kód umiestnený pod dokumentom 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, ktorý musíte umiestniť do súboru HBaseConnection.java a musíte spustiť program Java
Po spustení tohto programu sa chystá nadviazať spojenie s HBase a následne vytvorí tabuľku s názvami stĺpcov.
- Názov tabuľky je „guru99“
- Názvy stĺpcov sú „vzdelávanie“ a „projekty“
Krok 4) Môžeme skontrolovať, či je tabuľka "guru99" vytvorená s dvoma stĺpcami v HBase alebo nie, pomocou režimu shell HBase s príkazom "list".
Príkaz "list" poskytuje informácie o všetkých tabuľkách, ktoré sú vytvorené v HBase.
Na tejto obrazovke budeme robiť
- Kontrola kódu v prostredí HBase vykonaním príkazu "list".
- Ak spustíme príkaz „list“, zobrazí sa tabuľka vytvorená v HBase, ako je uvedené nižšie. V našom prípade vidíme, že je vytvorená tabuľka „guru99“
HBase Vytvorenie tabuľky pomocou aplikácie Shell
Syntax na vytvorenie tabuľky je
Syntax: create,
Príklad: -
hbase(main):001:0> create 'education' ,'guru99'0 rows(s) in 0.312 seconds=>Hbase::Table - education
Vyššie uvedený príklad vysvetľuje, ako vytvoriť tabuľku v HBase so zadaným názvom zadaným podľa slovníka alebo špecifikácií podľa rodiny stĺpcov. Okrem toho do nej môžeme vložiť aj niektoré atribúty rozsahu tabuľky.
create 'guru99', {NAME=>'Edu', VERSIONS=>213423443}
Zhrnutie:
HBase je stĺpcovo orientovaná databáza NoSQL na ukladanie veľkého množstva údajov navrch ekosystému Hadoop. Manipulácia s tabuľkami v HBase je veľmi zásadná vec, pretože všetky dôležité funkcie, ako sú dátové operácie, vylepšenia údajov a dátové modelovanie, môžeme vykonávať iba prostredníctvom tabuliek v HBase. Tabuľky vykonávajú nasledujúce funkcie 1) Vytváranie tabuliek s názvami stĺpcov a riadkami 2) Vkladanie hodnôt do tabuliek 3) Načítanie hodnôt z tabuliek