În HBase, putem crea operații de tabel în două moduri
- Comanda Shell
- API JAVA
Vom învăța să le folosim pe ambele pentru a crea tabele.
- HBase Creați tabelul cu Java API
- HBase Creați tabel cu Shell
HBase creează un tabel cu Java API
În această secțiune, vom efectua unele dintre operațiuni folosind codarea Java prin Java API.
Prin intermediul API-ului Java, putem crea tabele în HBase și, de asemenea, putem încărca date în tabele folosind codarea Java.
- Stabilirea unei conexiuni cu HBase prin intermediul API-ului Java
- Utilizarea Eclipse pentru codare, depanare și testare Java
Stabilirea conexiunii prin Java API:
Pașii următori ne ghidează să dezvoltăm cod Java pentru a conecta HBase prin API Java.
Pasul 1) În acest pas, vom crea un proiect Java în eclipsă pentru conexiunea HBase.
Crearea noului nume de proiect „HbaseConnection” în eclipsă.
Pentru configurarea proiectului legat de Java sau crearea programului
Dacă observăm captura de ecran de mai sus.
- Dați numele proiectului în această casetă. În cazul nostru, avem numele proiectului „HbaseConnection”
- Bifați această casetă pentru a fi salvată locația implicită. În acest / home / hduser / work / HbaseConnection este calea
- Bifați caseta pentru mediul Java aici. În acest JavaSE-1.7 este ediția Java
- Alegeți opțiunea unde doriți să salvați fișierul. În cazul nostru, am selectat opțiunea a doua „Creați un dosar separat pentru surse și fișiere de clasă”
- Faceți clic pe butonul de finisare.
- Când faceți clic pe butonul Finalizare, va crea proiectul „HbaseConnection” în eclipsă
- Va apărea direct pe pagina principală Eclipse după ce faceți clic pe butonul de finalizare.
Pasul 2) Pe pagina de pornire a eclipsei urmați pașii următori
Right click on project -> Select Build Path -> Configure build path
Din imaginea de mai sus
- Faceți clic dreapta pe un proiect
- Selectați calea de construire
- Selectați configurare cale de construire
După ce faceți clic pe Configurare cale de construire, se va deschide o altă fereastră așa cum se arată în captura de ecran de mai jos
În acest pas, vom adăuga borcane relevante HBase în proiectul Java așa cum se arată în captura de ecran.
- Borcane importante care trebuie adăugate hbase-0.94.8.jar, hadoop-core-1.1.2.jar
- Faceți clic pe butonul de finisare
- Vino la biblioteci
- Apăsați opțiunea - Adăugați borcane externe
- Selectați borcanele importante necesare
- Apăsați butonul de finalizare pentru a adăuga aceste fișiere la „src” al proiectului java din biblioteci
După adăugarea acestor borcane, se va afișa sub locația proiectului "src". Toate fișierele Jar care intră sub incidența proiectului sunt acum gata de utilizare cu ecosistemul Hadoop.
Pasul 3) În acest pas, utilizând HBaseConnection.java, conexiunea HBase ar fi stabilită prin codarea Java
- În meniul de sus Eclipse, executați un program Java așa cum se arată mai jos
Rulați -> Rulați ca -> Aplicație Java
- Selectați Run
- Selectați Executare ca aplicație Java
- Acest cod va stabili o conexiune cu HBase prin Java API
- După rularea acestui cod, tabelul 'guru99' va fi creat în HBase cu două familii de coloane numite „educație” și „proiecte”. În prezent, schema goală este creată numai în HBase.
Din captura de ecran de mai sus efectuăm următoarele funcții.
- Folosind HTableDescriptor putem crea tabelul „guru99” în HBase
- Folosind metoda addFamily, vom adăuga „educație” și „proiecte” ca nume de coloane în tabelul „guru99”.
Codificarea de mai jos urmează
- Stabiliți o conexiune cu HBase și
- Creați un tabel „guru99” cu două coloane
Cod plasat în documentul 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… ");}}
Acesta este codul obligatoriu pe care trebuie să îl plasați în HBaseConnection.java și să rulați un program java
După rularea acestui program, va stabili o conexiune cu HBase și, la rândul său, va crea un tabel cu nume de coloane.
- Numele tabelului este „guru99”
- Numele coloanelor sunt „educație” și „proiecte”
Pasul 4) Putem verifica dacă tabelul „guru99” este creat cu două coloane în HBase sau nu utilizând modul shell HBase cu comanda „list”.
Comanda „listă” oferă informații despre toate tabelele create în HBase.
În acest ecran, vom face
- Verificarea codului în shell-ul HBase executând comanda „list”.
- Dacă executăm comanda „listă”, aceasta va afișa tabelul creat în HBase ca mai jos. În cazul nostru, putem vedea tabelul „guru99” este creat
HBase Creați tabel cu Shell
Sintaxa pentru a crea un tabel este
Syntax: create,
Exemplu:-
hbase(main):001:0> create 'education' ,'guru99'0 rows(s) in 0.312 seconds=>Hbase::Table - education
Exemplul de mai sus explică cum să creați un tabel în HBase cu numele specificat dat conform dicționarului sau specificațiilor conform familiei de coloane. În plus, putem trece și câteva atribute ale domeniului tabelului.
create 'guru99', {NAME=>'Edu', VERSIONS=>213423443}
Rezumat:
HBase este o bază de date NoSQL orientată pe coloane pentru stocarea unei cantități mari de date deasupra ecosistemului Hadoop. Gestionarea tabelelor în HBase este un lucru foarte crucial, deoarece toate funcționalitățile importante, cum ar fi operațiile de date, îmbunătățirile datelor și modelarea datelor, putem fi efectuate numai prin tabele în HBase. Tabelele îndeplinesc următoarele funcții 1) Crearea tabelelor cu nume de coloane și rânduri 2) Introducerea valorilor în tabele 3) Recuperarea valorilor din tabele