Exemplo de consulta HBase: comandos put(), get() e scan()

Gravar dados na tabela HBase: Shell

Esses exemplos pressupõem que o HBase esteja instalado e funcionando, o shell do HBase está aberto e um tabela chamada guru99 já existe uma coluna com projetos e educação para famílias.

O comando put é usado para armazenar dados em uma tabela.

Syntax:  put <'tablename'>,<'rowname'>,<'columnvalue'>,<'value'>

Este comando é usado para os seguintes fins:

• Ele colocará um 'valor' de célula em uma tabela, linha ou coluna definida ou especificada.
• Opcionalmente, poderá incluir um registro de data e hora.

Por exemplo, aqui estamos inserindo valores na tabela “guru99” na linha r1 e coluna c1:

hbase> put 'guru99', 'r1', 'c1', 'value', 10

Inserimos três valores, 10, 15 e 30, na tabela “guru99”, conforme mostrado na captura de tela abaixo.

Suponha que a tabela “guru99” tenha uma referência de tabela, como g. Você também pode executar o comando na referência da tabela, assim:

hbase> g.put 'guru99', 'r1', 'c1', 'value', 10

O resultado aparece conforme mostrado na captura de tela acima após inserir valores em “guru99”.

Ler dados da tabela HBase: Shell

Nesta seção, verificamos o seguinte no Shell do HBase:

• Valores que são inseridos na tabela HBase “guru99”.
• Nomes das colunas com os valores presentes na tabela HBase guru99.

A saída da análise abaixo lista todos os valores inseridos em “guru99”, juntamente com os nomes de suas linhas e colunas:

A partir da captura de tela acima, podemos inferir o seguinte:

• Se executarmos o comando “scan” no shell do HBase, ele exibirá os valores inseridos em “guru99” da seguinte forma.
• No shell do HBase, serão exibidos os valores inseridos pelo nosso código, juntamente com os nomes das colunas e linhas.
• Aqui podemos ver que os nomes das colunas inseridos são “educação” e “projetos”.
• Os valores inseridos nas colunas mencionadas foram “BigData” e “Tutoriais HBase”.

Você também pode usar o comando get para ler dados de uma tabela.

Syntax: get <'tablename'>, <'rowname'>, {< Additional parameters>}

Aqui, os parâmetros adicionais incluem TIMERANGE, TIMESTAMP, VERSIONS e FILTERS. Usando este comando, você obtém uma linha ou o conteúdo de uma célula presente na tabela. Você pode adicionar parâmetros adicionais, como TIMESTAMP, TIMERANGE, VERSIONS ou FILTERS, para buscar uma linha ou o conteúdo de uma célula específica. A tabela abaixo resume esses parâmetros:

Aqui estão alguns exemplos práticos do comando get:

hbase> get 'guru99', 'r1', {COLUMN => 'c1'}

Para a tabela “guru99”, os valores da linha r1 e da coluna c1 serão exibidos usando este comando, conforme mostrado na captura de tela abaixo.

hbase> get 'guru99', 'r1'

Para a tabela “guru99”, os valores da linha r1 serão exibidos usando este comando.

hbase> get 'guru99', 'r1', {TIMERANGE => [ts1, ts2]}

Para a tabela “guru99”, os valores da linha r1 no intervalo de tempo ts1 a ts2 serão exibidos usando este comando.

hbase> get 'guru99', 'r1', {COLUMN => ['c1', 'c2', 'c3']}

Para a tabela “guru99”, os valores da linha r1 e das famílias de colunas c1, c2 e c3 serão exibidos usando este comando.

Gravar dados na tabela HBase: API JAVA

Nesta etapa, vamos gravar dados na tabela HBase “guru99”.

Primeiro, precisamos escrever o código para inserir e recuperar valores do HBase, usando o programa HBaseLoading.java. Para criar e inserir valores em uma tabela no nível da coluna, o código deve ser escrito conforme mostrado abaixo.

A captura de tela abaixo mostra o Java Código que constrói a configuração do HBase e insere valores em “guru99”:

Conforme a captura de tela acima:

• Ao criarmos a configuração do HBase, ela aponta para quaisquer configurações que tenhamos definido nos arquivos hbase-site.xml e hbase-default.xml durante a instalação do HBase.
• Criação da tabela “guru99” usando o método HTable.
• Adicionando a linha 1 à tabela “guru99”.
• Especificando os nomes das colunas “education” e “projects” e inserindo valores nos nomes das colunas na respectiva linha1. Os valores inseridos aqui são BigData e “Tutoriais HBase”.

Leia os dados da tabela HBase: Java API

Quaisquer valores que tenhamos inserido na tabela HBase na seção anterior serão recuperados e exibidos aqui.

A saída do console abaixo mostra os dados sendo lidos da tabela HBase “guru99”:

Para recuperar resultados armazenados em “guru99”:

• Aqui, vamos buscar os valores armazenados nas famílias de colunas, ou seja, “education” e “projects”.
• Utilizando o comando “get”, vamos buscar os valores armazenados na tabela HBase.
• Resultados da leitura usando o comando “scan”. Os valores armazenados na linha 1 serão exibidos no console.

Depois de escrever o código, você executa o Java Formulário on line como isso:

Clique com o botão direito do mouse em HBaseLoading.java -> Executar como -> Java Aplicação.

Após executar o arquivo “HBaseLoading.java”, os valores são inseridos em “guru99” em cada coluna do HBase, e o mesmo programa também pode recuperar os valores.

Aqui está o código completo:

import java.io.IOException;
import org.apache.hadoop.hbase.HBaseConfiguration;
import org.apache.hadoop.hbase.client.Get;
import org.apache.hadoop.hbase.client.HTable;
import org.apache.hadoop.hbase.client.Put;
import org.apache.hadoop.hbase.client.Result;
import org.apache.hadoop.hbase.client.ResultScanner;
import org.apache.hadoop.hbase.client.Scan;
import org.apache.hadoop.hbase.util.Bytes;
public class HBaseLoading
{
public static void main(String[] args) throws IOException
{
/* When you create a HBaseConfiguration, it reads in whatever you've set into your hbase-site.xml and in hbase-default.xml, as long as these can be found on the CLASSPATH*/

org.apache.hadoop.conf.Configuration config = HBaseConfiguration.create();

/*This instantiates an HTable object that connects you to the "test" table*/

HTable table = new HTable(config, "guru99");

/* To add to a row, use Put. A Put constructor takes the name of the row you want to insert into as a byte array.*/

Put p = new Put(Bytes.toBytes("row1"));

/*To set the value you'd like to update in the row 'row1', specify the column family, column qualifier, and value of the table cell you'd like to update. The column family must already exist in your table schema. The qualifier can be anything.*/

p.add(Bytes.toBytes("education"), Bytes.toBytes("col1"),Bytes.toBytes("BigData"));
p.add(Bytes.toBytes("projects"),Bytes.toBytes("col2"),Bytes.toBytes("HBaseTutorials"));

// Once you've adorned your Put instance with all the updates you want to make, to commit it do the following

table.put(p);

// Now, to retrieve the data we just wrote.

Get g = new Get(Bytes.toBytes("row1"));
Result r = table.get(g);

byte [] value = r.getValue(Bytes.toBytes("education"),Bytes.toBytes("col1"));
byte [] value1 = r.getValue(Bytes.toBytes("projects"),Bytes.toBytes("col2"));
String valueStr = Bytes.toString(value);

String valueStr1 = Bytes.toString(value1);
System.out.println("GET: " +"education: "+ valueStr+"projects: "+valueStr1);

Scan s = new Scan();

s.addColumn(Bytes.toBytes("education"), Bytes.toBytes("col1"));
s.addColumn(Bytes.toBytes("projects"), Bytes.toBytes("col2"));
ResultScanner scanner = table.getScanner(s);
try
{
for (Result rr = scanner.next(); rr != null; rr = scanner.next())
{
System.out.println("Found row : " + rr);
}
} finally
{
// Make sure you close your scanners when you are done!

scanner.close();
}
}
}

Nota sobre as versões da API: O exemplo acima usa a classe HTable e seu método add(), que refletem a API de cliente HBase mais antiga. Desde o HBase 1.0, o HTable está obsoleto. O código moderno obtém uma tabela por meio de ConnectionFactory.createConnection(…).getTable(…) e constrói uma operação Put com addColumn() em vez de add(). A lógica de put, get e scan permanece a mesma.

Perguntas Frequentes