HBase - opisz i zmień
opisać
To polecenie zwraca opis tabeli. Jego składnia jest następująca:
hbase> describe 'table name'
Poniżej podano wynik działania polecenia opisującego w pliku emp stół.
hbase(main):006:0> describe 'emp'
DESCRIPTION
ENABLED
'emp', {NAME ⇒ 'READONLY', DATA_BLOCK_ENCODING ⇒ 'NONE', BLOOMFILTER
⇒ 'ROW', REPLICATION_SCOPE ⇒ '0', COMPRESSION ⇒ 'NONE', VERSIONS ⇒
'1', TTL true
⇒ 'FOREVER', MIN_VERSIONS ⇒ '0', KEEP_DELETED_CELLS ⇒ 'false',
BLOCKSIZE ⇒ '65536', IN_MEMORY ⇒ 'false', BLOCKCACHE ⇒ 'true'}, {NAME
⇒ 'personal
data', DATA_BLOCK_ENCODING ⇒ 'NONE', BLOOMFILTER ⇒ 'ROW',
REPLICATION_SCOPE ⇒ '0', VERSIONS ⇒ '5', COMPRESSION ⇒ 'NONE',
MIN_VERSIONS ⇒ '0', TTL
⇒ 'FOREVER', KEEP_DELETED_CELLS ⇒ 'false', BLOCKSIZE ⇒ '65536',
IN_MEMORY ⇒ 'false', BLOCKCACHE ⇒ 'true'}, {NAME ⇒ 'professional
data', DATA_BLO
CK_ENCODING ⇒ 'NONE', BLOOMFILTER ⇒ 'ROW', REPLICATION_SCOPE ⇒ '0',
VERSIONS ⇒ '1', COMPRESSION ⇒ 'NONE', MIN_VERSIONS ⇒ '0', TTL ⇒
'FOREVER', K
EEP_DELETED_CELLS ⇒ 'false', BLOCKSIZE ⇒ '65536', IN_MEMORY ⇒
'false', BLOCKCACHE ⇒ 'true'}, {NAME ⇒ 'table_att_unset',
DATA_BLOCK_ENCODING ⇒ 'NO
NE', BLOOMFILTER ⇒ 'ROW', REPLICATION_SCOPE ⇒ '0', COMPRESSION ⇒
'NONE', VERSIONS ⇒ '1', TTL ⇒ 'FOREVER', MIN_VERSIONS ⇒ '0',
KEEP_DELETED_CELLS
⇒ 'false', BLOCKSIZE ⇒ '6
zmieniać
Alter to polecenie używane do wprowadzania zmian w istniejącej tabeli. Za pomocą tego polecenia można zmienić maksymalną liczbę komórek w rodzinie kolumn, ustawić i usunąć operatory zakresu tabeli oraz usunąć rodzinę kolumn z tabeli.
Zmiana maksymalnej liczby komórek w rodzinie kolumn
Poniżej podano składnię zmiany maksymalnej liczby komórek w rodzinie kolumn.
hbase> alter 't1', NAME ⇒ 'f1', VERSIONS ⇒ 5
W poniższym przykładzie maksymalna liczba komórek jest ustawiona na 5.
hbase(main):003:0> alter 'emp', NAME ⇒ 'personal data', VERSIONS ⇒ 5
Updating all regions with the new schema...
0/1 regions updated.
1/1 regions updated.
Done.
0 row(s) in 2.3050 seconds
Operatory zakresu tabeli
Za pomocą alter można ustawiać i usuwać operatory zakresu tabeli, takie jak MAX_FILESIZE, READONLY, MEMSTORE_FLUSHSIZE, DEFERRED_LOG_FLUSH itp.
Ustawienie tylko do odczytu
Poniżej podana jest składnia, aby tabela była tylko do odczytu.
hbase>alter 't1', READONLY(option)
W poniższym przykładzie utworzyliśmy plik emp tabela tylko do odczytu.
hbase(main):006:0> alter 'emp', READONLY
Updating all regions with the new schema...
0/1 regions updated.
1/1 regions updated.
Done.
0 row(s) in 2.2140 seconds
Usuwanie operatorów zakresu tabeli
Możemy również usunąć operatory zakresu tabeli. Poniżej podano składnię usuwania „MAX_FILESIZE” z tabeli emp.
hbase> alter 't1', METHOD ⇒ 'table_att_unset', NAME ⇒ 'MAX_FILESIZE'
Usuwanie rodziny kolumn
Używając alter, możesz również usunąć rodzinę kolumn. Poniżej podano składnię usuwania rodziny kolumn za pomocą funkcji alter.
hbase> alter ‘ table name ’, ‘delete’ ⇒ ‘ column family ’
Poniżej podano przykład usuwania rodziny kolumn z tabeli „emp”.
Załóżmy, że w HBase istnieje tabela o nazwie pracownik. Zawiera następujące dane:
hbase(main):006:0> scan 'employee'
ROW COLUMN+CELL
row1 column = personal:city, timestamp = 1418193767, value = hyderabad
row1 column = personal:name, timestamp = 1418193806767, value = raju
row1 column = professional:designation, timestamp = 1418193767, value = manager
row1 column = professional:salary, timestamp = 1418193806767, value = 50000
1 row(s) in 0.0160 seconds
Teraz usuńmy nazwaną rodzinę kolumn professional używając polecenia alter.
hbase(main):007:0> alter 'employee','delete'⇒'professional'
Updating all regions with the new schema...
0/1 regions updated.
1/1 regions updated.
Done.
0 row(s) in 2.2380 seconds
Teraz zweryfikuj dane w tabeli po zmianie. Zauważ, że rodzina kolumn „profesjonalny” już nie istnieje, ponieważ ją usunęliśmy.
hbase(main):003:0> scan 'employee'
ROW COLUMN + CELL
row1 column = personal:city, timestamp = 14181936767, value = hyderabad
row1 column = personal:name, timestamp = 1418193806767, value = raju
1 row(s) in 0.0830 seconds
Dodawanie rodziny kolumn za pomocą Java API
Za pomocą tej metody można dodać rodzinę kolumn do tabeli addColumn() z HBAseAdminklasa. Wykonaj czynności podane poniżej, aby dodać rodzinę kolumn do tabeli.
Krok 1
Utwórz wystąpienie HBaseAdmin klasa.
// Instantiating configuration object
Configuration conf = HBaseConfiguration.create();
// Instantiating HBaseAdmin class
HBaseAdmin admin = new HBaseAdmin(conf);
Krok 2
Plik addColumn() metoda wymaga nazwy tabeli i obiektu HColumnDescriptorklasa. Dlatego utwórz wystąpienieHColumnDescriptorklasa. KonstruktorHColumnDescriptorz kolei wymaga dodania nazwy rodziny kolumn. Tutaj dodajemy rodzinę kolumn o nazwie „contactDetails” do istniejącej tabeli „pracownik”.
// Instantiating columnDescriptor object
HColumnDescriptor columnDescriptor = new
HColumnDescriptor("contactDetails");
Krok 3
Dodaj rodzinę słupów za pomocą addColumnmetoda. Podaj nazwę tabeli iHColumnDescriptor class jako parametry tej metody.
// Adding column family
admin.addColumn("employee", new HColumnDescriptor("columnDescriptor"));
Poniżej podano kompletny program dodawania rodziny kolumn do istniejącej tabeli.
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.MasterNotRunningException;
import org.apache.hadoop.hbase.client.HBaseAdmin;
public class AddColoumn{
public static void main(String args[]) throws MasterNotRunningException, IOException{
// Instantiating configuration class.
Configuration conf = HBaseConfiguration.create();
// Instantiating HBaseAdmin class.
HBaseAdmin admin = new HBaseAdmin(conf);
// Instantiating columnDescriptor class
HColumnDescriptor columnDescriptor = new HColumnDescriptor("contactDetails");
// Adding column family
admin.addColumn("employee", columnDescriptor);
System.out.println("coloumn added");
}
}
Skompiluj i wykonaj powyższy program, jak pokazano poniżej.
$javac AddColumn.java
$java AddColumn
Powyższa kompilacja działa tylko wtedy, gdy ustawiłeś ścieżkę klas w „ .bashrc”. Jeśli nie, postępuj zgodnie z procedurą podaną poniżej, aby skompilować plik .java.
//if "/home/home/hadoop/hbase " is your Hbase home folder then.
$javac -cp /home/hadoop/hbase/lib/*: Demo.java
Jeśli wszystko pójdzie dobrze, wygeneruje następujący wynik:
column added
Usuwanie rodziny kolumn za pomocą Java API
Za pomocą tej metody można usunąć rodzinę kolumn z tabeli deleteColumn() z HBAseAdminklasa. Wykonaj czynności podane poniżej, aby dodać rodzinę kolumn do tabeli.
Krok 1
Utwórz wystąpienie HBaseAdmin klasa.
// Instantiating configuration object
Configuration conf = HBaseConfiguration.create();
// Instantiating HBaseAdmin class
HBaseAdmin admin = new HBaseAdmin(conf);
Krok 2
Dodaj rodzinę słupów za pomocą deleteColumn()metoda. Przekaż nazwę tabeli i nazwę rodziny kolumn jako parametry do tej metody.
// Deleting column family
admin.deleteColumn("employee", "contactDetails");
Poniżej podano kompletny program do usuwania rodziny kolumn z istniejącej tabeli.
import java.io.IOException;
import org.apache.hadoop.conf.Configuration;
import org.apache.hadoop.hbase.HBaseConfiguration;
import org.apache.hadoop.hbase.MasterNotRunningException;
import org.apache.hadoop.hbase.client.HBaseAdmin;
public class DeleteColoumn{
public static void main(String args[]) throws MasterNotRunningException, IOException{
// Instantiating configuration class.
Configuration conf = HBaseConfiguration.create();
// Instantiating HBaseAdmin class.
HBaseAdmin admin = new HBaseAdmin(conf);
// Deleting a column family
admin.deleteColumn("employee","contactDetails");
System.out.println("coloumn deleted");
}
}
Skompiluj i wykonaj powyższy program, jak pokazano poniżej.
$javac DeleteColumn.java
$java DeleteColumn
Wynik powinien być następujący:
column deleted