HBase táblázat létrehozása példával

Tartalomjegyzék:

Anonim

A HBase-ben kétféle módon hozhatunk létre tábla műveleteket

  • Shell parancs
  • JAVA API

Megtanuljuk használni mindkettőt a Táblák készítéséhez.

  • HBase Tábla létrehozása Java API-val
  • HBase Táblázat létrehozása a Shell segítségével

A HBase létrehoz egy táblázatot Java API-val

Ebben a részben néhány műveletet végrehajtunk Java kódolással a Java API-n keresztül.

A Java API-n keresztül táblákat hozhatunk létre a HBase-ben, és adatokat is tölthetünk táblákba Java kódolással.

  • Kapcsolat létrehozása a HBase programmal Java API-n keresztül
  • Az Eclipse használata Java kódoláshoz, hibakereséshez és teszteléshez

Kapcsolat létrehozása Java API-n keresztül:

A következő lépések arra irányítanak minket, hogy dolgozzunk Java kódot a HBase Java API-n keresztüli összekapcsolásához.

1. lépés: Ebben a lépésben Java-projektet fogunk létrehozni a HBase kapcsolathoz való napfogyatkozásban.

Új projektnév "HbaseConnection" létrehozása a napfogyatkozásban.

Java-val kapcsolatos projektek létrehozása vagy program létrehozása

Ha megfigyeljük a fenti képernyőképet.

  1. Adja meg a projekt nevét ebben a mezőben. Esetünkben megvan a "HbaseConnection" projektnév
  2. Jelölje be ezt a négyzetet az alapértelmezett mentési helyhez. Ebben / home / hduser / work / HbaseConnection az elérési út
  3. Itt jelölje be a Java környezet jelölőnégyzetét. Ebben a JavaSE-1.7 a Java kiadás
  4. Válassza ki azt a lehetőséget, ahová a fájlt menteni kívánja. Esetünkben a második lehetőséget választottuk: "Külön mappa létrehozása a forrásokhoz és az osztályfájlokhoz"
  5. Kattintson a Befejezés gombra.
  • Ha rákattint a Befejezés gombra, akkor a "HbaseConnection" projektet létrehozza a napfogyatkozásban
  • A Befejezés gombra kattintás után közvetlenül eljut a kezdőlapra.

2. lépés) Az eclipse kezdőlapján kövesse az alábbi lépéseket

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

Felülről képernyőkép

  1. Kattintson a jobb gombbal a projektre
  2. Válassza ki az összeállítási útvonalat
  3. Válassza ki az összeállítási útvonal konfigurálása lehetőséget

Az Építési útvonal konfigurálása gombra kattintás után megnyílik egy másik ablak, amint az az alábbi képernyőképen látható

Ebben a lépésben hozzáadjuk a releváns HBase edényeket a java projekthez, ahogyan a képernyőképen látható.

  • Fontos üvegek hozzáadása: hbase-0.94.8.jar, hadoop-core-1.1.2.jar
  • Kattintson a Befejezés gombra

  1. Gyere könyvtárakba
  2. Nyomja meg az Opció gombot - Külső üvegek hozzáadása
  3. Válassza ki a szükséges fontos üvegeket
  4. Nyomja meg a Befejezés gombot, ha ezeket a fájlokat hozzá szeretné adni a java projekt 'src' könyvtárához

Miután hozzáadta ezeket az üvegeket, a projekt az "src" alatt jelenik meg. A projekt alá tartozó összes Jar fájl készen áll a Hadoop ökoszisztémával való használatra.

3. lépés: Ebben a lépésben a HBaseConnection.java használatával a HBase kapcsolatot a Java kódolással lehet létrehozni

  • Az Eclipse felső menüjében hajtson végre egy java programot az alábbiak szerint

    Futtatás -> Futtatás másként -> Java alkalmazás

  1. Válassza a Futtatás lehetőséget
  2. Válassza a Futtatás Java alkalmazásként lehetőséget
  • Ez a kód kapcsolatot létesít a HBase programmal a Java API-n keresztül
  • A kód futtatása után a „guru99” tábla létrejön a HBase-ban két oszlopcsaláddal, amelyek neve „oktatás” és „projektek”. Jelenleg az üres séma csak a HBase-ben jön létre.

A fenti képernyőképről a következő funkciókat hajtjuk végre.

  1. A HTableDescriptor segítségével létrehozhatunk "guru99" táblázatot a HBase-ben
  2. Az addFamily módszerrel hozzáadjuk az "oktatás" és a "projektek" oszlopneveket a "guru99" táblához.

Az alábbi kódolás megy

  • Hozza létre a kapcsolatot a HBase és
  • Hozzon létre két oszlopos "guru99" táblázatot

Kód elhelyezve a HBaseConnection_Java dokumentum alatt

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

Ez a szükséges kód, amelyet be kell helyeznie a HBaseConnection.java fájlba, és futtatnia kell egy java programot

A program futtatása után kapcsolatot fog létesíteni a HBase-szel, és létrehoz egy táblázatot oszlopnevekkel.

  • A táblázat neve: "guru99"
  • Az oszlopnevek: "oktatás" és "projektek"

4. lépés: Megvizsgálhatjuk, hogy a "guru99" tábla két oszloppal készül-e a HBase-ben, vagy sem a HBase shell mód használatával a "list" paranccsal.

A "list" parancs információt nyújt a HBase-ben létrehozott összes tábláról.

Ezen a képernyőn meg fogjuk tenni

  • Kódellenőrzés a HBase shellben a "list" parancs végrehajtásával.
  • Ha a "list" parancsot futtatjuk, akkor a HBase-ben létrehozott táblázatot az alábbiak szerint jeleníti meg. Esetünkben láthatjuk, hogy a "guru99" táblázat létrejön

HBase Táblázat létrehozása a Shell segítségével

A táblázat létrehozásának szintaxisa

Syntax: create 
, 

Példa:-

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

A fenti példa elmagyarázza, hogyan hozhat létre táblázatot a HBase-ben a megadott névvel, amely a szótár vagy a specifikációk szerint oszlopcsaládonként szerepel. Ezen felül átadhatunk néhány tábla-hatókör attribútumot is.

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

Összegzés:

A HBase egy oszloporientált NoSQL adatbázis, amely nagy mennyiségű adatot tárol a Hadoop ökoszisztéma tetején. A táblázatok kezelése a HBase-ben nagyon fontos dolog, mert minden fontos funkciót, például az adatműveleteket, az adatfejlesztéseket és az adatmodellezést, csak a HBase-ben lévő táblákon keresztül tudjuk végrehajtani. A táblázatok a következő funkciókat látják el: 1) Táblázatok létrehozása oszlopnevekkel és sorokkal