HBase Criar Tabela com Exemplo

No HBase, podemos criar operações de tabela de duas maneiras

  • Comando shell
  • API JAVA

Vamos aprender a usar ambos para criar tabelas.

HBase cria uma tabela com API Java

Nesta seção, vamos realizar algumas das operações usando a codificação Java por meio da API Java.

Por meio da API Java, podemos criar tabelas no HBase e também carregar dados em tabelas usando a codificação Java.

  • Estabelecendo uma conexão com o HBase por meio da API Java
  • Usando Eclipse para codificação, depuração e teste de Java

Estabelecendo conexão por meio da API Java:

As etapas a seguir nos orientam a desenvolver o código Java para conectar o HBase por meio da API Java.

Passo 1) Nesta etapa, vamos criar um projeto Java no eclipse para conexão HBase.

Criação do novo nome do projeto 'HbaseConnection' no eclipse.

Para configuração de projeto relacionado a Java ou criação de programa

Se observarmos a imagem acima.

  1. Dê o nome do projeto nesta caixa. No nosso caso, temos o nome do projeto 'HbaseConnection'
  2. Marque esta caixa para salvar o local padrão. Neste / home / hduser / work / HbaseConnection é o caminho
  3. Marque a caixa para o ambiente Java aqui. Neste JavaSE-1.7 está a edição Java
  4. Escolha sua opção onde deseja salvar o arquivo. Em nosso caso, selecionamos a segunda opção 'Criar uma pasta separada para fontes e arquivos de classe'
  5. Clique no botão Concluir.
  • Quando você clicar no botão Concluir, ele criará o projeto 'HbaseConnection' no eclipse
  • Ele virá diretamente para a página inicial do eclipse após clicar no botão Concluir.

Passo 2) Na página inicial do eclipse, siga as seguintes etapas

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

Da captura de tela acima

  1. Clique com o botão direito em um projeto
  2. Selecione o caminho de construção
  3. Selecione configurar caminho de construção

Depois de clicar em Configurar caminho de compilação, ele abrirá outra janela, conforme mostrado na captura de tela 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 terminar

  1. Venha para bibliotecas
  2. Pressione a opção - Adicionar Frascos Externos
  3. Selecione os frascos importantes necessários
  4. Pressione o botão Concluir para adicionar esses arquivos a 'src' do projeto Java nas bibliotecas

Depois de adicionar esses jars, ele será mostrado na localização do projeto 'src'. Todos os arquivos Jar que se enquadram no projeto agora estão prontos para uso com o ecossistema Hadoop.

Etapa 3) Nesta etapa, usando HBaseConnection.java, a conexão HBase seria estabelecida por meio da codificação Java

  • No menu superior do Eclipse, execute um programa java conforme mostrado abaixo

    Executar -> Executar como -> Aplicativo Java

  1. Selecione Executar
  2. Selecione Executar como aplicativo Java
  • Este código estabelecerá uma conexão com o HBase por meio da API Java
  • Depois de executar este código, a tabela 'on2vhf' será criada no HBase com duas famílias de colunas denominadas 'educação' e 'projetos'. No momento, o esquema vazio é criado apenas no HBase.

Na captura de tela acima, estamos executando as seguintes funções.

  1. Usando HTableDescriptor, podemos criar a tabela 'on2vhf' no HBase
  2. Usando o método addFamily, vamos adicionar 'educação' e 'projetos' como nomes de coluna na tabela 'on2vhf'.

A codificação abaixo vai

  • Estabeleça uma conexão com o HBase e
  • Crie a tabela 'on2vhf' com duas colunas

Código colocado no documento HBaseConnection_Java

// 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('on2vhf'); 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 programa 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 mesa é 'on2vhf'
  • Os nomes das colunas são 'educação' e 'projetos'

Passo 4) Podemos verificar se a tabela 'on2vhf' é criada com duas colunas no HBase ou não usando o modo shell do HBase com o comando 'list'.

O comando 'list' fornece informações sobre todas as tabelas criadas no HBase.

Nesta tela, vamos fazer

  • Verificação de código no shell do HBase executando o comando 'list'.
  • Se executarmos o comando 'list', ele exibirá a tabela criada no HBase como abaixo. No nosso caso, podemos ver a tabela 'on2vhf' criada

HBase Criar tabela com Shell

A sintaxe para criar uma tabela é

Syntax: create , 

Exemplo:-

hbase(main):001:0> create 'education' ,'on2vhf' 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 'on2vhf', {NAME=>'Edu', VERSIONS=>213423443}

Resumo:

HBase é um banco de dados NoSQL orientado a colunas para armazenar uma grande quantidade de dados no ecossistema Hadoop. Manipular tabelas no HBase é uma coisa muito importante porque todas as funcionalidades importantes, como operações de dados, melhorias de dados e modelagem de dados, podem ser realizadas apenas por meio de tabelas no HBase. As tabelas desempenham as seguintes funções 1) Criação de tabelas com nomes de colunas e linhas 2) Inserção de valores nas tabelas 3) Recuperação de valores das tabelas