HBase Luo taulukko Java API & Shell esimerkki

Kuinka luoda taulukko HBaseen kanssa Java API

HBasessa taulukoita voidaan luoda kahdella tavalla: Java API:n ja HBase-komentotulkin kautta. Tämä osio käsittelee Java API, jonka avulla sovellus voi luoda taulukoita ja ladata tietoja ohjelmallisesti osana suurempaa työtä.

Kautta Java API, voimme luoda taulukoita HBaseen ja myös ladata tietoja taulukoihin käyttämällä Java koodaus. Kaksi asiaa, jotka tässä asetettiin, ovat:

• Yhteyden luominen HBaseen kautta Java API.
• Käyttäminen Eclipse varten Java koodausta, virheenkorjausta ja testausta.

Seuraavassa on vaiheet taulukoiden luomiseksi HBase kautta Java API.

Vaihe 1) Luo a Java Projekti sisään Eclipse

Tässä vaiheessa aiomme luoda a Java projekti vuonna Eclipse HBase-yhteydelle nimeltä ”HbaseConnection”.

Uusi Java Alla oleva projektivalintaikkuna näyttää, kuinka ”HbaseConnection”-projektia ollaan määrittämässä:

Jos tarkastelemme yllä olevaa kuvakaappausta:

• Anna projektin nimi tähän ruutuun. Meidän tapauksessamme projektin nimi on ”HbaseConnection”.
• Valitse tämä ruutu, jos haluat käyttää oletussijaintia tallennuspaikaksi. Tässä polku on /home/hduser/work/HbaseConnection.
• Valitse valintaruutu Java ympäristö täällä. Tässä tapauksessa JavaSE-1.7 on Java painos.
• Valitse vaihtoehto, mihin haluat tallentaa tiedoston. Meidän tapauksessamme valitsimme toisen vaihtoehdon, ”Luo ​​erillinen kansio lähde- ja luokkatiedostoille”.
• Napsauta Valmis-painiketta, joka luo ”HbaseConnection”-projektin Eclipse ja avaa Eclipse etusivulle.

Vaihe 2) Määritä rakennuspolku kohdassa Eclipse

On Eclipse kotisivulla, avaa rakennuspolun määritys seuraavasti:

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

Alla olevassa kuvakaappauksessa näkyy hiiren kakkospainikkeella avattava valikko, jota käytetään rakennuspolun määritysten avaamiseen:

Yllä olevasta kuvakaappauksesta:

• Napsauta projektia hiiren kakkospainikkeella.
• Valitse Rakennuspolku.
• Valitse Määritä koontipolku.

Kun olet napsauttanut Configure Build Path -painiketta, avautuu uusi ikkuna, kuten alla olevassa kuvakaappauksessa näkyy. Kirjastot-välilehdellä HBase- ja Hadoop JAR -tiedostot lisätään projektiin:

Tässä vaiheessa lisäämme asiaankuuluvat HBase JAR -tiedostot Java projekti, kuten kuvakaappauksessa näkyy.

• Tärkeitä lisättäviä JAR-tiedostoja: hbase-0.94.8.jar ja hadoop-core-1.1.2.jar.
• Tule Kirjastot-välilehdelle.
• Paina vaihtoehtoa Lisää ulkoisia JAR-tiedostoja.
• Valitse tarvittavat tärkeät JAR-tiedostot.
• Lisää nämä tiedostot sovelluksen "src"-kansioon painamalla Valmis-painiketta. Java projekti Kirjastot-osiossa.

Kun JAR-tiedostot on lisätty, ne näkyvät projektin ”src”-sijainnissa alla olevan kuvan mukaisesti:

Kaikki projektiin kuuluvat JAR-tiedostot ovat nyt käyttövalmiita Hadoop-ekosysteemissä.

Vaihe 3) Muodosta HBase-yhteys

Tässä vaiheessa HBase-yhteys muodostetaan HBaseConnection.java-tiedoston avulla Java koodaus.

On Eclipse ylävalikko, suorita Java ohjelma kuten alla näkyy: Suorita -> Suorita nimellä -> Java Sovellus. Alla oleva valikko näyttää käynnistettävän ohjelman:

• Valitse Suorita.
• Valitse Suorita nimellä Java Sovellus.
• Tämä koodi muodostaa yhteyden HBaseen seuraavan kautta: Java API.
• Tämän koodin suorittamisen jälkeen HBase-järjestelmään luodaan ”guru99”-taulukko, jossa on kaksi sarakeperhettä nimeltä ”education” ja ”projects”. Tällä hetkellä HBase-järjestelmään luodaan vain tyhjä skeema.

Alla oleva koodiote korostaa HTableaDescripttai ja addFamily-kutsuja, jotka rakentavat taulukkorakenteen:

Yllä olevasta kuvakaappauksesta suoritamme seuraavat toiminnot:

• HTablen käyttöDescripttai voimme luoda "guru99"-taulukon HBase:ssa.
• Käyttämällä addFamily-metodia lisäämme ”guru99”-taulukkoon sarakeperheinä ”koulutus” ja ”projektit”.

Alla oleva koodi muodostaa yhteyden HBaseen ja luo "guru99"-taulukon, jossa on kaksi sarakeperhettä. Sijoita tämä koodi HBaseConnection.java-dokumentin alle:

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

Tämä on pakollinen koodi, joka sinun on sijoitettava HBaseConnection.java-tiedostoon ennen komennon suorittamista Java ohjelma.

Suoritettuaan tämän ohjelman se muodostaa yhteyden HBaseen ja luo puolestaan ​​taulukon sarakenimineen.

• Taulukon nimi on “guru99”.
• Sarakeperheet ovat ”koulutus” ja ”projektit”.

Vaihe 4) Tarkista HBaseen luotu taulukko

Voimme tarkistaa, onko "guru99"-taulukko luotu kahdella sarakeperheellä HBase-käyttöliittymässä, käyttämällä HBase-komentotulkkitilaa "list"-komennolla. "List"-komento antaa tietoja kaikista HBase-käyttöliittymässä luoduista taulukoista.

HBase-komennon list-komennon suorittaminen vahvistaa uuden taulukon, kuten alla on esitetty:

• Code tarkistamalla HBase-kuoren suorittamalla komennon "list".
• Jos suoritamme komennon ”list”, se näyttää HBase-ohjelmassa luodun taulukon. Meidän tapauksessamme voimme nähdä, että ”guru99”-taulukko on luotu.

HBase Luo taulukko Shellillä

Lisäksi Java API:n avulla voit luoda taulukon suoraan HBase-komennosta, mikä on nopein tapa määrittää taulukko nopeita testejä varten. Taulukon luomisen syntaksi HBase-komennon avulla on seuraava:

Syntax: create <tablename>, <columnfamilyname>

Esimerkki: -

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

Yllä oleva esimerkki selittää, kuinka HBase-järjestelmässä luodaan taulukko, jonka nimi annetaan kunkin sarakeperheen määritysten mukaisesti. Tämän lisäksi voimme myös välittää siihen joitakin taulukon laajuusattribuutteja.

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

Tässä lohko {NAME=>'Edu', VERSIONS=>…} asettaa sarakeperheen nimeltä ”Edu” ja sen säilyttämien soluversioiden määrän. Suuri luku on vain havainnollistava; käytännössä VERSIONS on pieni arvo, kuten 3 tai 5.

HBase-taulukoiden listaaminen, kuvailu ja varmentaminen

Taulukon luominen on vasta ensimmäinen osa taulukoiden käsittelystä HBase-ohjelmassa. Kun ”guru99”-taulukko on olemassa, voit tarkastella sitä ja vahvistaa sen tilan muutamalla yleisellä komennolla ennen tietojen lukemista, kirjoittamista tai muokkaamista. Voit suorittaa kaikki komennot… HBase-kuori.

list-komento palauttaa jokaisen käyttäjätaulukon HBase-järjestelmässä:

hbase> list

describe-komento näyttää taulukon rakenteen, mukaan lukien sen sarakeperheet ja sen, onko se tällä hetkellä käytössä:

hbase> describe 'guru99'

Komento exists tarkistaa, onko taulukko olemassa, ja is_enabled raportoi, voiko taulukko hyväksyä kirjoituksia:

hbase> exists 'guru99'
hbase> is_enabled 'guru99'

Näitä vain luku -tilassa olevia tarkistuksia voi turvallisesti suorittaa milloin tahansa. Ne ovat nopein tapa varmistaa, että taulukko on luotu oikein, ja tarkistaa sen sarakeperheet ennen tietojen lataamista.

Muuta HBase-taulukkoa

HBase-taulukon rakennetta ei korjata luomisen jälkeen. alter-komento muuttaa taulukon sarakeperheitä ja taulukon laajuusattribuutteja luomatta sitä uudelleen. HBase-versiostasi riippuen sinun on ehkä ensin poistettava taulukko käytöstä ja sitten suoritettava alter-komento ja otettava se uudelleen käyttöön.

Uuden sarakeperheen lisääminen ”guru99”-taulukkoon:

hbase> alter 'guru99', {NAME => 'contact'}

Sarakeperheen säilyttämien versioiden määrän määrittäminen:

hbase> alter 'guru99', NAME => 'education', VERSIONS => 5

Sarakeperheen poistaminen taulukosta:

hbase> alter 'guru99', {NAME => 'contact', METHOD => 'delete'}

Voit myös muuttaa taulukon laajuusmääritteitä. Voit esimerkiksi merkitä taulukon vain luku -tilaan tai asettaa aluetiedoston enimmäiskooksi 128 Mt:n:

hbase> alter 'guru99', READONLY
hbase> alter 'guru99', MAX_FILESIZE => '134217728'

Koska alter kirjoittaa skeeman uudelleen, suunnittele muutokset huolellisesti tuotantotaulukossa ja vahvista tulos jälkikäteen describe-komennolla.

HBase-taulukoiden poistaminen käytöstä, ottaminen käyttöön ja poistaminen

Taulukon poistamiseksi tai tiettyjen muutosten tekemiseksi HBase vaatii sen ensin poistamista käytöstä. Pois käytöstä poistaminen siirtää taulukon offline-tilaan, joten kukaan asiakas ei voi lukea tai kirjoittaa siihen, mikä tekee rakenteellisista muutoksista turvallisia.

Poista taulukko käytöstä ja tarkista sen tila is_disabled-metodilla:

hbase> disable 'guru99'
hbase> is_disabled 'guru99'

Ota taulukko uudelleen käyttöön jatkaaksesi lukemista ja kirjoittamista:

hbase> enable 'guru99'

Taulukko on poistettava käytöstä ennen kuin se voidaan pudottaa.ping poistaa taulukon ja kaikki sen tiedot pysyvästi, joten käytä sitä varoen:

hbase> disable 'guru99'
hbase> drop 'guru99'

Useiden taulukoiden poistamiseksi kerralla drop_all poistaa kaikki taulukot, joiden nimi vastaa säännöllistä lauseketta. Yhdessä luonti, muuttaminen, poistaminen käytöstä, käyttöönotto ja poistaminen kattavat koko taulukon elinkaaren. tietojen käsittely HBase-taulukoissa.

UKK