HBase Opret tabel med eksempel

Indholdsfortegnelse:

Anonim

I HBase kan vi oprette tabeloperationer på to måder

  • Shell-kommando
  • JAVA API

Vi lærer at bruge begge dele til at oprette tabeller.

  • HBase Opret tabel med Java API
  • HBase Opret tabel med Shell

HBase oprette en tabel med Java API

I dette afsnit skal vi udføre nogle af operationerne ved hjælp af Java-kodning via Java API.

Via Java API kan vi oprette tabeller i HBase og også indlæse data i tabeller ved hjælp af Java-kodning.

  • Oprettelse af en forbindelse med HBase via Java API
  • Brug af Eclipse til Java-kodning, fejlretning og test

Oprettelse af forbindelse via Java API:

De følgende trin guider os til at udvikle Java-kode til at forbinde HBase via Java API.

Trin 1) I dette trin skal vi oprette et Java-projekt i formørkelse til HBase-forbindelse.

Oprettelse af nyt projektnavn "HbaseConnection" i formørkelse.

Til Java-relateret projekt opsætning eller oprettelse af program

Hvis vi observerer skærmbilledet ovenfor.

  1. Angiv projektnavn i dette felt. I vores tilfælde har vi projektnavnet "HbaseConnection"
  2. Marker dette felt for standardplacering, der skal gemmes. I denne / home / hduser / work / HbaseConnection er stien
  3. Marker afkrydsningsfeltet for Java-miljø her. I denne JavaSE-1.7 er Java-udgaven
  4. Vælg din indstilling, hvor du vil gemme filen. I vores tilfælde har vi valgt valgmulighed andet "Opret en separat mappe til kilder og klassefiler"
  5. Klik på finish-knappen.
  • Når du klikker på knappen Afslut, oprettes det "HbaseConnection" -projekt i formørkelse
  • Det kommer direkte til formørkelsessiden efter at have klikket på knappen Afslut.

Trin 2) På formørkelsens startside skal du følge følgende trin

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

Fra ovenstående skærmbillede

  1. Højreklik på et projekt
  2. Vælg byggesti
  3. Vælg konfigurer build-sti

Efter at have klikket på Konfigurer opbyg sti, åbner det et andet vindue som vist i nedenstående skærmbillede

I dette trin vil vi tilføje 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

  1. Kom til biblioteker
  2. Tryk på option - Tilføj eksterne krukker
  3. Vælg de nødvendige vigtige krukker
  4. Tryk på finish-knappen for at tilføje disse filer til 'src' i java-projekt under biblioteker

Efter tilføjelse af disse krukker vises den under projektets "src" placering. Alle Jar-filer, der falder ind under projektet, er nu klar til brug i Hadoop-økosystemet.

Trin 3) I dette trin ved hjælp af HBaseConnection.java, oprettes HBase-forbindelsen via Java-kodning

  • I Eclipse-topmenuen skal du udføre et java-program som vist nedenfor

    Kør -> Kør som -> Java-applikation

  1. Vælg Kør
  2. Vælg Kør som Java-applikation
  • Denne kode opretter forbindelse til HBase via Java API
  • Efter kørsel af denne kode oprettes 'guru99' -tabellen i HBase med to kolonnefamilier med navnet "uddannelse" og "projekter". På nuværende tidspunkt oprettes det tomme skema kun i HBase.

Fra skærmbilledet ovenfor udfører vi følgende funktioner.

  1. Ved hjælp af HTableDescriptor kan vi oprette "guru99" -tabellen i HBase
  2. Ved hjælp af addFamily-metoden vil vi tilføje "uddannelse" og "projekter" som kolonnenavne til "guru99" -tabellen.

Nedenstående kodning vil

  • Opret forbindelse med HBase og
  • Opret "guru99" tabel med to kolonner

Kode placeret under HBaseConnection_Java-dokument 

// 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… ");}}

Denne krævede kode skal du placere i HBaseConnection.java og skal køre et java-program

Efter at have kørt dette program, opretter det en forbindelse med HBase, og det opretter igen en tabel med kolonnenavne.

  • Tabellens navn er "guru99"
  • Kolonnenavne er "uddannelse" og "projekter"

Trin 4) Vi kan kontrollere, om "guru99" -tabellen oprettes med to kolonner i HBase eller ej ved hjælp af HBase-shell-tilstand med "list" -kommandoen.

Kommandoen "liste" giver information om alle de tabeller, der oprettes i HBase.

I denne skærm skal vi gøre

  • Kodekontrol i HBase shell ved at udføre kommandoen "list".
  • Hvis vi kører "liste" -kommandoen, viser den tabellen oprettet i HBase som nedenfor. I vores tilfælde kan vi se, at tabellen "guru99" er oprettet

HBase Opret tabel med Shell

Syntaks for at oprette en tabel er

Syntax: create 
,

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 angivne navn i henhold til ordbogen eller specifikationerne pr. Kolonnefamilie. Ud over dette kan vi også videregive nogle attributter i tabelområdet til det.

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

Resumé:

HBase er en kolonneorienteret NoSQL-database til lagring af en stor mængde data oven på Hadoop-økosystemet. Håndtering af tabeller i HBase er en meget vigtig ting, fordi alle vigtige funktioner såsom datahandlinger, dataforbedringer og datamodellering kun kan udføres gennem tabeller i HBase. Tabeller udfører følgende funktioner 1) Oprettelse af tabeller med kolonnenavne og rækker 2) Indsættelse af værdier i tabeller 3) Hentning af værdier fra tabeller