Ustvari tabelo HBase s primerom

Kazalo:

Anonim

V HBase lahko ustvarimo operacije tabel na dva načina

  • Ukaz lupine
  • API JAVA

Naučili se bomo uporabljati oboje za ustvarjanje tabel.

  • Ustvari tabelo HBase z Java API
  • HBase Ustvari tabelo s školjko

HBase ustvari tabelo z Java API

V tem poglavju bomo nekatere postopke izvedli z uporabo Java kodiranja prek Java API.

Preko Java API lahko ustvarjamo tabele v HBase in podatke nalagamo tudi v tabele z uporabo Java kodiranja.

  • Vzpostavitev povezave s HBase prek Java API
  • Uporaba Eclipse za kodiranje, odpravljanje napak in testiranje na Javi

Vzpostavitev povezave prek Java API:

Naslednji koraki nas vodijo k razvoju Java kode za povezavo HBase prek Java API.

Korak 1) V tem koraku bomo ustvarili projekt Java v eclipse za povezavo HBase.

Ustvarjanje novega imena projekta "HbaseConnection" v mrku.

Za vzpostavitev ali izdelavo programa, povezanega z Javo

Če opazujemo zgornji posnetek zaslona.

  1. V tem polju navedite ime projekta. V našem primeru imamo ime projekta "HbaseConnection"
  2. Označite to polje, če želite shraniti privzeto lokacijo. V tem / home / hduser / work / HbaseConnection je pot
  3. Tu potrdite polje za okolje Java. V tej JavaSE-1.7 je izdaja Java
  4. Izberite svojo možnost, kamor želite shraniti datoteko. V našem primeru smo izbrali možnost druga "Ustvari ločeno mapo za vire in datoteke razredov"
  5. Kliknite gumb za zaključek.
  • Ko kliknete gumb Dokončaj, bo v mrku ustvaril projekt "HbaseConnection"
  • Ko kliknete gumb za dokončanje, bo neposredno prišel na domačo stran eclipse.

Korak 2) Na domači strani eclipse sledite naslednjim korakom

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

Posnetek zaslona od zgoraj

  1. Z desno miškino tipko kliknite projekt
  2. Izberite pot gradnje
  3. Izberite konfiguriranje poti gradnje

Ko kliknete Konfiguriraj pot gradnje, se odpre novo okno, kot je prikazano na spodnjem posnetku zaslona

V tem koraku bomo v java projekt dodali ustrezne kozarce HBase, kot je prikazano na posnetku zaslona.

  • Pomembne kozarce, ki jih je treba dodati hbase-0.94.8.jar, hadoop-core-1.1.2.jar
  • Kliknite gumb za zaključek

  1. Pridite v knjižnice
  2. Pritisnite možnost - Dodaj zunanje kozarce
  3. Izberite potrebne pomembne kozarce
  4. Pritisnite gumb za dokončanje, da dodate te datoteke v 'src' projekta java v knjižnicah

Po dodajanju teh kozarcev se bo prikazal pod lokacijo projekta "src". Vse datoteke Jar, ki spadajo v projekt, so zdaj pripravljene za uporabo v ekosistemu Hadoop.

Korak 3) V tem koraku bi z uporabo HBaseConnection.java povezavo HBase vzpostavili s pomočjo Java Coding

  • V zgornjem meniju Eclipse zaženite program java, kot je prikazano spodaj

    Zaženi -> Zaženi kot -> Aplikacija Java

  1. Izberite Zaženi
  2. Izberite Zaženi kot aplikacijo Java
  • Ta koda bo vzpostavila povezavo s HBase prek Java API
  • Po zagonu bo v HBase ustvarjena tabela 'guru99' z dvema družinama stolpcev z imenom "izobraževanje" in "projekti". Trenutno je prazna shema ustvarjena samo v HBase.

Na zgornjem posnetku zaslona izvajamo naslednje funkcije.

  1. S pomočjo HTableDescriptor lahko v HBase ustvarimo tabelo "guru99"
  2. Z uporabo metode addFamily bomo v tabelo "guru99" kot imena stolpcev dodali "izobraževanje" in "projekte".

Spodnje kodiranje bo

  • Vzpostavite povezavo s HBase in
  • Ustvari tabelo "guru99" z dvema stolpcema

Koda umeščena pod dokument 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… ");}}

To je potrebna koda, ki jo morate namestiti v HBaseConnection.java in zagnati java program

Po zagonu tega programa bo vzpostavil povezavo s HBase, nato pa bo ustvaril tabelo z imeni stolpcev.

  • Ime tabele je "guru99"
  • Imena stolpcev so "izobraževanje" in "projekti"

Korak 4) Lahko preverimo, ali je tabela "guru99" ustvarjena z dvema stolpcema v HBase ali ne, z uporabo načina lupine HBase z ukazom "list".

Ukaz "seznam" vsebuje informacije o vseh tabelah, ki so ustvarjene v HBase.

Na tem zaslonu bomo to storili

  • Preverjanje kode v lupini HBase z izvajanjem ukaza "list".
  • Če zaženemo ukaz "list", bo prikazal tabelo, ustvarjeno v HBase, kot spodaj. V našem primeru lahko vidimo, da je ustvarjena tabela "guru99"

HBase Ustvari tabelo s školjko

Sintaksa za ustvarjanje tabele je

Syntax: create 
,

Primer: -

hbase(main):001:0> create 'education' ,'guru99'0 rows(s) in 0.312 seconds=>Hbase::Table - education

Zgornji primer pojasnjuje, kako v HBase ustvariti tabelo z navedenim imenom, podanim v skladu s slovarjem ali specifikacijami glede na družino stolpcev. Poleg tega lahko vanj prenesemo tudi nekatere atribute obsega tabele.

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

Povzetek:

HBase je stolpčno usmerjena baza podatkov NoSQL za shranjevanje velike količine podatkov na vrhu Hadoopovega ekosistema. Ravnanje s tabelami v HBase je zelo ključna stvar, saj lahko vse pomembne funkcije, kot so podatkovne operacije, izboljšave podatkov in modeliranje podatkov, izvajamo samo s tabelami v HBase. Tabele opravljajo naslednje funkcije 1) Ustvarjanje tabel z imeni stolpcev in vrsticami 2) Vstavljanje vrednosti v tabele 3) Pridobivanje vrednosti iz tabel