Створення таблиці HBase з прикладом

Зміст:

Anonim

У HBase ми можемо створювати операції з таблицями двома способами

  • Команда оболонки
  • API JAVA

Ми навчимось використовувати обидва для створення таблиць.

  • Створення таблиці HBase за допомогою API Java
  • HBase Створити таблицю за допомогою оболонки

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. Клацніть на кнопку закінчити.
  • Коли ви натискаєте кнопку Готово, він створює проект "HbaseConnection" у затемненні
  • Він безпосередньо потрапить на домашню сторінку 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 буде встановлено за допомогою кодування Java

  • У верхньому меню Eclipse запустіть програму Java, як показано нижче

    Виконати -> Запустити як -> Додаток Java

  1. Виберіть Виконати
  2. Виберіть Запустити як додаток Java
  • Цей код встановить зв'язок з 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 Створити таблицю за допомогою оболонки

Синтаксис для створення таблиці є

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) Отримання значень з таблиць