HBase Creați tabel cu Java Exemplu API și Shell
David Carter
În HBase, putem crea operații de tabel în două moduri:
- API-ul Java
- Comanda Shell
Vom învăța să le folosim pe ambele pentru a crea tabele în HBase:
Cum se creează un tabel în HBase cu Java API
În această secțiune, vom efectua unele dintre operațiunile folosind Java codificare prin Java API-ul.
Prin Java API, putem crea tabele în HBase și, de asemenea, putem încărca date în tabele folosind Java codare.
- Stabilirea unei conexiuni cu HBase prin Java API
- Utilizarea Eclipse pentru Java codificare, depanare și testare
Stabilirea conexiunii prin Java API-uri:
Următorii sunt pașii pentru a crea tabele în HBase prin Java API-uri:
Pasul 1) Creați un Java Proiect în Eclipse
În acest pas, vom crea un Java proiect in Eclipse pentru conexiunea HBase.
Crearea unui nou nume de proiect „HbaseConnection” în eclipse.
Pentru Java înființarea proiectului aferent sau crearea unui program
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 ca locația implicită să fie salvată. În acest /home/hduser/work/HbaseConnection este calea
- Bifați caseta pentru Java mediu aici. In aceasta JavaSE-1.7 este Java ediţie
- Alegeți opțiunea unde doriți să salvați fișierul. În cazul nostru, am selectat a doua opțiune „Creați un folder separat pentru surse și fișiere de clasă”
- Faceți clic pe butonul de finalizare.
- Când faceți clic pe butonul Terminare, acesta va crea proiectul „HbaseConnection” în eclipse
- Va ajunge direct la pagina de pornire Eclipse după ce faceți clic pe butonul de finalizare.
Pasul 2) Configurați calea de construcție în Eclipse
On Eclipse pagina principală, urmați următorii pași:
Right click on project -> Select Build Path -> Configure build path
Din captura de ecran de mai sus:
- Faceți clic dreapta pe un proiect
- Selectați calea de construcție
- Selectați configurați calea de construcție
După ce faceți clic pe Configure Build path, 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 HBase relevante în proiectul java, așa cum se arată în captură de ecran.
- Borcane importante de adăugat hbase-0.94.8.jar, hadoop-core-1.1.2.jar
- Faceți clic pe butonul de finalizare
- 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 în locația proiectului „src”. Toate fișierele Jar care se încadrează în proiect sunt acum gata de utilizare cu ecosistemul Hadoop.
Pasul 3) Stabiliți conexiunea HBase
În acest pas, prin utilizarea HBaseConnection.java, conexiunea HBase va fi stabilită prin Java Codificare
- On Eclipse meniul de sus, executați un program java așa cum se arată mai josRun -> Run As -> Java Aplicatii
- Selectați Run
- Selectați Executare ca Java Aplicatii
- 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ă doar în HBase.
Din captura de ecran de mai sus, efectuăm următoarele funcții:
- Folosind HTableDescriptsau putem crea tabelul „guru99” în HBase
- Folosind metoda addFamily, vom adăuga „educație” și „proiecte” ca nume de coloane la tabelul „guru99”.
Codarea de mai jos va urma:
- Stabiliți o conexiune cu HBase și
- Creați un tabel „guru99” cu două coloane
Cod plasat sub HBaseConnection_Java document
// 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......");
}
}
Acesta este codul necesar pe care trebuie să îl plasați în HBaseConnection.java și să rulați un Java programul.
După rularea acestui program, acesta 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) Verificați tabelul creat în HBase
Putem verifica dacă tabelul „guru99” este creat cu două coloane în HBase sau nu prin utilizarea Carcasa HBase modul cu comanda „listă”.
Comanda „listă” oferă informații despre toate tabelele care sunt create în HBase.
În acest ecran, vom face
- Verificarea codului în shell HBase prin executarea comenzii „list”.
- Dacă rulăm comanda „list”, va afișa tabelul creat în HBase ca mai jos. În cazul nostru, putem vedea tabelul „guru99” creat
HBase Creați tabel cu Shell
Sintaxa pentru a crea un tabel în HBase folosind Shell este:
Syntax: create <tablename>, <columnfamilyname>
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. Pe lângă aceasta, putem trece și unele atribute de tabelă în el.
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 Ecosistemul Hadoop.
- Manipularea tabelelor în HBase este un lucru foarte esențial, deoarece toate funcționalitățile importante, cum ar fi operațiunile de date, îmbunătățirile de date și modelarea datelor, pot fi efectuate numai prin tabele din HBase.
- Tabelele îndeplinesc următoarele funcții:
- Crearea de tabele cu nume de coloane și rânduri
- Inserarea valorilor în tabele
- Preluarea valorilor din tabele
