HBase Criar tabela com Java Exemplo de API e Shell
David Carter
No HBase, podemos criar operações de tabela de duas maneiras:
- API JAVA
- Comando Shell
Aprenderemos a usar ambos para criar tabelas no HBase:
Como criar tabela no HBase com Java API
Nesta seção, realizaremos algumas das operações usando Java codificação através Java API.
Através da Java API, podemos criar tabelas em HBase e também carregar dados em tabelas usando Java codificação.
- Estabelecendo uma conexão com o HBase por meio de Java API
- utilização Eclipse for Java codificação, depuração e teste
Estabelecendo conexão através Java API:
A seguir estão as etapas para criar tabelas no HBase por meio de Java API:
Etapa 1) Crie um Java Projeto em Eclipse
Nesta etapa, vamos criar um Java projeto em Eclipse para conexão HBase.
Criação do novo nome de projeto “HbaseConnection” no Eclipse.
Para a Java configuração de projeto relacionado ou criação de programa
Se observarmos a imagem acima.
- Dê o nome do projeto nesta caixa. No nosso caso, temos o nome do projeto “HbaseConnection”
- Marque esta caixa para o local padrão a ser salvo. Neste /home/hduser/work/HbaseConnection está o caminho
- Marque a caixa para Java ambiente aqui. Nesta JavaSE-1.7 é o Java edição
- Escolha a opção onde deseja salvar o arquivo. No nosso caso, selecionamos a segunda opção “Criar uma pasta separada para fontes e arquivos de classe”
- Clique no botão Concluir.
- Ao clicar no botão Concluir, será criado o projeto “HbaseConnection” no Eclipse
- Ele irá diretamente para a página inicial do Eclipse após clicar no botão Concluir.
Etapa 2) Configure o caminho de construção em Eclipse
On Eclipse página inicial, siga os seguintes passos:
Right click on project -> Select Build Path -> Configure build path
Da captura de tela acima:
- Clique com o botão direito em um projeto
- Selecione o caminho de construção
- Selecione configurar caminho de construção
Depois de clicar em Configurar caminho de construção, outra janela será aberta conforme mostrado na imagem abaixo
Nesta etapa, adicionaremos jars HBase relevantes ao projeto Java, conforme mostrado na captura de tela.
- Jars importantes a serem adicionados hbase-0.94.8.jar, hadoop-core-1.1.2.jar
- Clique no botão finalizar
- Venha para as bibliotecas
- Pressione a opção – Adicionar Jars Externos
- Selecione os frascos importantes necessários
- Pressione o botão Concluir para adicionar esses arquivos ao 'src' do projeto Java nas bibliotecas
Depois de adicionar esses jars, ele será exibido no local “src” do projeto. Todos os arquivos Jar incluídos no projeto agora estão prontos para uso com o ecossistema Hadoop.
Etapa 3) Estabeleça a conexão HBase
Nesta etapa, usando HBaseConnection.java, a conexão HBase seria estabelecida através de Java Codificação
- On Eclipse menu superior, execute um programa java como mostrado abaixoExecutar -> Executar como -> Java Solicitações
- Selecione Executar
- Selecione Executar como Java Solicitações
- Este código estabelecerá uma conexão com o HBase através Java API
- Após a execução deste código, a tabela 'guru99' será criada no HBase com dois grupos de colunas denominados “educação” e “projetos”. Atualmente, o esquema vazio é criado apenas no HBase.
Na captura de tela acima, estamos executando as seguintes funções:
- Usando HTableDescriptou podemos criar a tabela “guru99” no HBase
- Usando o método addFamily, adicionaremos “educação” e “projetos” como nomes de colunas à tabela “guru99”.
A codificação abaixo irá:
- Estabeleça uma conexão com o HBase e
- Crie a tabela “guru99” com duas colunas
Código colocado em HBaseConnection_Java documento
// 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......");
}
}
Este é o código necessário que você deve colocar em HBaseConnection.java e executar um Java .
Após executar este programa, ele estabelecerá uma conexão com o HBase e por sua vez criará uma tabela com os nomes das colunas.
- O nome da tabela é “guru99”
- Os nomes das colunas são “educação” e “projetos”
Etapa 4) Verifique a tabela criada no HBase
Podemos verificar se a tabela “guru99” foi criada com duas colunas no HBase ou não usando Shell do HBase modo com o comando “lista”.
O comando “list” fornece informações sobre todas as tabelas criadas no HBase.
Nesta tela faremos
- Verificação de código no shell HBase executando o comando “list”.
- Se executarmos o comando “list”, ele exibirá a tabela criada no HBase conforme abaixo. No nosso caso, podemos ver que a tabela “guru99” foi criada
HBase Criar Tabela com Shell
A sintaxe para criar uma tabela no HBase usando Shell é:
Syntax: create <tablename>, <columnfamilyname>
Exemplo:-
hbase(main):001:0> create 'education' ,'guru99' 0 rows(s) in 0.312 seconds =>Hbase::Table – education
O exemplo acima explica como criar uma tabela no HBase com o nome especificado fornecido de acordo com o dicionário ou especificações de acordo com a família de colunas. Além disso, também podemos passar alguns atributos de escopo de tabela para ele.
create 'guru99', {NAME=>'Edu', VERSIONS=>213423443}
Resumo
- HBase é um banco de dados NoSQL orientado a colunas para armazenar uma grande quantidade de dados sobre Ecossistema Hadoop.
- O manuseio de tabelas no HBase é algo muito importante porque todas as funcionalidades importantes, como operações de dados, aprimoramentos de dados e modelagem de dados, podem ser realizadas apenas por meio de tabelas no HBase.
- As tabelas executam as seguintes funções:
- Criação de tabelas com nomes de colunas e linhas
- Inserindo valores em tabelas
- Recuperando valores de tabelas