1. Configurarea mediului HBase 2.x
Aici, pentru că este doar pentru a testa utilizarea API-ului Java HBase, am implementat doar o versiune independentă a serviciului în mașina virtuală locală, iar mediul de producție poate implementa singur modul cluster. Trebuie menționat, de asemenea, că unele dintre porturile de ascultare ale versiunii stand-alone a serviciului HBase sunt legate de versiunea 127.0.0.1 a mașinii virtuale, ceea ce face imposibilă conectarea la HBase folosind API-ul Java pe mașina fizică. Soluția mea este să folosesc SecureCRT pentru a configura maparea porturilor relevantă, informațiile specifice de mapare fiind următoarele:
2. Explicație detaliată despre utilizarea celui mai recent API Java pentru operarea HBase 2.x
(1) Adăugarea următoarelor dependențe la proiectul Spring Boot/Spring Cloud:
(2) Operații de bază legate de HBase:
(3) Adaugă informații de configurare HBase:
Atributele specifice folosite sunt următoarele:
(4) Testează metodele de bază de mai sus:
i) Ștergerea, crearea tabelelor și a interogărilor de bază:
După rularea testelor unitare, ieșirea este următoarea:
ii) Interogare care specifică startRowKey și stopRowKey:
Această interogare este folosită în general atunci când RowKey este incrementată continuu și doar o parte din date este interogată (cum ar fi paginarea):
După rularea testelor unitare, ieșirea este următoarea:
iii) Obține toate denumirile tabelelor:
După rularea testelor unitare, ieșirea este următoarea:
iv) Obținerea datelor pentru mai multe versiuni ale unei celule specificate:
După rularea testelor unitare, ieșirea este următoarea:
Notă: Deoarece HBase salvează implicit doar o singură versiune, efectul nu este vizibil aici.
v) Interogarea datelor pe baza filtrelor de chei rând:
După rularea testelor unitare, ieșirea este următoarea:
vi) Interogarea datelor pe baza filtrului de nume de coloane:
După rularea testelor unitare, ieșirea este următoarea:
vii) Interogarea datelor care conțin caractere specifice în cheile de rând:
După rularea testelor unitare, ieșirea este următoarea:
viii) Șterge coloana specificată:
După rularea testelor unitare, ieșirea este următoarea:
ix) Șterge linia specificată:
După rularea testelor unitare, ieșirea este următoarea:
Conform rezultatului, se poate observa că această linie de date a fost într-adevăr ștearsă.
x) Șterge familia de coloane specificată:
După rularea testelor unitare, ieșirea este următoarea:
Conform rezultatului, se poate constata că familia de coloane "back" a fost ștearsă.
|
Postat pe 09.01.2019 13:57:39
|
|
|
|
Postat pe 05.06.2019 16:18:18