HBase Създаване на таблица с пример

Съдържание:

Anonim

В HBase можем да създаваме операции по таблици по два начина

  • Командна черупка
  • API на JAVA

Ще се научим да използваме и двете за създаване на таблици.

  • HBase Създаване на таблица с Java API
  • HBase Създаване на таблица с Shell

HBase създава таблица с Java API

В този раздел ще извършим някои от операциите, използвайки Java кодиране чрез Java API.

Чрез Java API можем да създаваме таблици в HBase и също така да зареждаме данни в таблици, използвайки Java кодиране.

  • Установяване на връзка с HBase чрез Java API
  • Използване на Eclipse за Java кодиране, отстраняване на грешки и тестване

Установяване на връзка чрез Java API:

Следващите стъпки ни насочват към разработването на Java код за свързване на HBase чрез Java API.

Стъпка 1) В тази стъпка ще създадем Java проект в eclipse за HBase връзка.

Създаване на ново име на проект "HbaseConnection" в eclipse.

За свързан с Java проект за създаване или създаване на програма

Ако наблюдаваме екранната снимка по-горе.

  1. Посочете името на проекта в това поле. В нашия случай имаме името на проекта "HbaseConnection"
  2. Поставете отметка в това квадратче, за да се запази местоположението по подразбиране. В този / home / hduser / work / HbaseConnection е пътят
  3. Поставете отметка в квадратчето за Java среда тук. В този JavaSE-1.7 е изданието на Java
  4. Изберете опцията си, където искате да запазите файл. В нашия случай сме избрали опция втора „Създаване на отделна папка за източници и файлове на класа“
  5. Щракнете върху бутона за финал.
  • Когато кликнете върху бутона Finish, той ще създаде проект "HbaseConnection" в eclipse
  • Той директно ще стигне до началната страница на eclipse, след като щракнете върху бутона за завършване.

Стъпка 2) На началната страница на eclipse следвайте следните стъпки

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

Екранна снимка отгоре

  1. Щракнете с десния бутон върху проект
  2. Изберете път на изграждане
  3. Изберете конфигуриране на пътя за изграждане

След като щракнете върху Конфигуриране на пътя за изграждане, той ще отвори друг прозорец, както е показано на екрана по-долу

В тази стъпка ще добавим съответни буркани HBase в java проект, както е показано на екранната снимка.

  • Важни буркани, които трябва да се добавят hbase-0.94.8.jar, hadoop-core-1.1.2.jar
  • Щракнете върху бутона за финал

  1. Елате в библиотеките
  2. Натиснете опция - Добавяне на външни буркани
  3. Изберете необходимите важни буркани
  4. Натиснете бутона за завършване, за да добавите тези файлове към 'src' на java проекта под библиотеки

След добавяне на тези буркани, той ще се покаже в местоположението на проекта "src". Всички Jar файлове, които попадат в проекта, вече са готови за използване с екосистемата Hadoop.

Стъпка 3) В тази стъпка с помощта на HBaseConnection.java, HBase Connection ще бъде установена чрез Java Coding

  • В горното меню на Eclipse изпълнете Java програма, както е показано по-долу

    Изпълнение -> Изпълнение като -> Приложение Java

  1. Изберете Run
  2. Изберете Run as Java Application
  • Този код ще установи връзка с HBase чрез Java API
  • След стартиране на този код в HBase ще бъде създадена таблица „guru99“ с две семейства колони, наречени „образование“ и „проекти“. Понастоящем празната схема се създава само в HBase.

От екранната снимка по-горе изпълняваме следните функции.

  1. Използвайки HTableDescriptor, можем да създадем таблица "guru99" в HBase
  2. Използвайки метода addFamily, ще добавим „образование“ и „проекти“ като имена на колони към таблицата „guru99“.

Кодирането по-долу ще бъде

  • Установете връзка с HBase и
  • Създайте таблица "guru99" с две колони

Код, поставен под документ HBaseConnection_Java 

// Place this code inside Hbase connectionimport 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… ");}}

Това е необходим код, който трябва да поставите в HBaseConnection.java и да стартирате Java програма

След като стартира тази програма, тя ще установи връзка с HBase и от своя страна ще създаде таблица с имена на колони.

  • Името на таблицата е "guru99"
  • Имената на колоните са „образование“ и „проекти“

Стъпка 4) Можем да проверим дали таблицата "guru99" е създадена с две колони в HBase или не, като използваме режима на черупката HBase с команда "list"

Командата "list" дава информация за всички таблици, създадени в HBase.

В този екран ще го направим

  • Проверка на кода в черупката на HBase чрез изпълнение на командата "list".
  • Ако изпълним командата "list", тя ще покаже таблицата, създадена в HBase, както е показано по-долу. В нашия случай можем да видим, че е създадена таблица "guru99"

HBase Създаване на таблица с Shell

Синтаксисът за създаване на таблица е

Syntax: create 
,

Пример: -

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

Горният пример обяснява как да създадете таблица в HBase с посоченото име, дадено според речника или спецификациите според семейството на колони. В допълнение към това можем да предадем и някои атрибути на обхвата на таблицата в него.

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

Резюме:

HBase е ориентирана към колони NoSQL база данни за съхраняване на голямо количество данни върху екосистемата на Hadoop. Работата с таблици в HBase е много важно нещо, защото всички важни функционалности като операции с данни, подобрения на данни и моделиране на данни можем да изпълняваме само чрез таблици в HBase. Таблиците изпълняват следните функции 1) Създаване на таблици с имена на колони и редове 2) Вмъкване на стойности в таблици 3) Извличане на стойности от таблици