HBase Opret tabel med Java API & Shell eksempel
David Carter
I HBase kan vi oprette tabeloperationer på to måder:
- Java API
- Shell kommando
Vi vil lære at bruge begge dele til at oprette tabeller i HBase:
Sådan opretter du tabel i HBase med Java API
I dette afsnit skal vi udføre nogle af operationerne ved hjælp af Java kodning igennem Java API.
Gennem Java API kan vi oprette tabeller i HBase og også indlæse data i tabeller vha Java kodning.
- Etablering af forbindelse med HBase gennem Java API
- Ved brug af Eclipse forum Java kodning, fejlretning og test
Etablering af forbindelse gennem Java API'er:
Følgende er trinene til at oprette tabeller i HBase igennem Java API'er:
Trin 1) Opret en Java Projekt i Eclipse
I dette trin skal vi skabe en Java projekt i Eclipse til HBase tilslutning.
Oprettelse af nyt projektnavn "HbaseConnection" i eclipse.
Til Java relateret projektopsætning eller oprettelse af program
Hvis vi observerer skærmbilledet ovenfor.
- Angiv projektnavn i denne boks. I vores tilfælde har vi projektnavnet "HbaseConnection"
- Marker dette felt for standardplacering, der skal gemmes. I denne /home/hduser/work/HbaseConnection er stien
- Marker afkrydsningsfeltet for Java miljøet her. I dette JavaSE-1.7 er Java udgave
- Vælg din mulighed, hvor du vil gemme filen. I vores tilfælde har vi valgt den anden mulighed "Opret en separat mappe til kilder og klassefiler"
- Klik på finish-knappen.
- Når du klikker på knappen Udfør, vil det oprette "HbaseConnection" -projekt i formørkelse
- Det kommer direkte til eclipse-hjemmesiden efter at have klikket på finish-knappen.
Trin 2) Konfigurer byggestien i Eclipse
On Eclipse startside, følg følgende trin:
Right click on project -> Select Build Path -> Configure build path
Fra ovenstående skærmbillede:
- Højreklik på et projekt
- Vælg byggesti
- Vælg konfigurer byggesti
Når du har klikket på Konfigurer byggesti, åbnes et andet vindue som vist på skærmbilledet nedenfor
I dette trin tilføjer vi relevante HBase-krukker til java-projektet som vist på skærmbilledet.
- Vigtige krukker, der skal tilføjes hbase-0.94.8.jar, hadoop-core-1.1.2.jar
- Klik på finish-knappen
- Kom til bibliotekerne
- Tryk på valgmulighed – Tilføj eksterne krukker
- Vælg nødvendige vigtige krukker
- Tryk på knappen Afslut for at tilføje disse filer til 'src' af java-projektet under biblioteker
Efter at have tilføjet disse krukker, vil det blive vist under projekt "src" placering. Alle Jar-filer, der falder ind under projektet, er nu klar til brug med Hadoop-økosystemet.
Trin 3) Etabler HBase-forbindelsen
I dette trin ved at bruge HBaseConnection.java, ville HBase Connection blive etableret igennem Java Kodning
- On Eclipse topmenuen, kør et java-program som vist nedenfor Kør -> Kør som -> Java Anvendelse
- Vælg Kør
- Vælg Kør som Java Anvendelse
- Denne kode vil etablere en forbindelse med HBase igennem Java API
- Efter at have kørt denne kode vil 'guru99'-tabellen blive oprettet i HBase med to kolonnefamilier kaldet "uddannelse" og "projekter". På nuværende tidspunkt oprettes det tomme skema kun i HBase.
Fra skærmbilledet ovenfor udfører vi følgende funktioner:
- Brug af HTableDescripteller vi kan oprette "guru99" tabel i HBase
- Ved at bruge addFamily-metoden vil vi tilføje "uddannelse" og "projekter" som kolonnenavne til tabellen "guru99".
Nedenstående kodning vil:
- Opret forbindelse med HBase og
- Opret "guru99" tabel med to kolonner
Kode placeret under HBaseConnection_Java dokumentet
// 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......");
}
}
Dette er påkrævet kode, du skal placere i HBaseConnection.java og skal køre en Java program.
Efter at have kørt dette program, vil det etablere en forbindelse med HBase, og til gengæld vil det oprette en tabel med kolonnenavne.
- Bordnavnet er "guru99"
- Kolonnenavne er "uddannelse" og "projekter"
Trin 4) Tjek den oprettede tabel i HBase
Vi kan kontrollere, om "guru99" tabel er oprettet med to kolonner i HBase eller ej ved at bruge HBase skal tilstand med kommandoen "liste".
Kommandoen "list" giver information om alle de tabeller, der er oprettet i HBase.
I denne skærm vil vi gøre
- Kodekontrol i HBase-shell ved at udføre "list"-kommandoen.
- Hvis vi kører "list"-kommandoen, vil den vise tabellen oprettet i HBase som nedenfor. I vores tilfælde kan vi se tabellen "guru99" er oprettet
HBase Opret tabel med Shell
Syntaksen til at oprette en tabel i HBase ved hjælp af Shell er:
Syntax: create <tablename>, <columnfamilyname>
Eksempel:-
hbase(main):001:0> create 'education' ,'guru99' 0 rows(s) in 0.312 seconds =>Hbase::Table – education
Ovenstående eksempel forklarer, hvordan man opretter en tabel i HBase med det specificerede navn givet i henhold til ordbogen eller specifikationerne i henhold til kolonnefamilien. Ud over dette kan vi også overføre nogle tabel-omfang-attributter ind i den.
create 'guru99', {NAME=>'Edu', VERSIONS=>213423443}
Resumé
- HBase er en kolonneorienteret NoSQL-database til lagring af en stor mængde data ovenpå Hadoop økosystem.
- Håndtering af tabeller i HBase er en meget afgørende ting, fordi alle vigtige funktionaliteter såsom dataoperationer, dataforbedringer og datamodellering kan udføres gennem kun tabeller i HBase.
- Tabeller udfører følgende funktioner:
- Oprettelse af tabeller med kolonnenavne og rækker
- Indsættelse af værdier i tabeller
- Henter værdier fra tabeller
