Intégration BigSQL-HBase

Question

Je suis novice à BigSQL. J'ai appris que HBase peut être intégré à BigSQL. J'avais essayé d'exécuter les commandes de création BigSQL-HBase après et avant de créer les tables HBase mais j'obtiens l'erreur qui est mentionnée ci-dessous.

SQL1:

CREATE HBASE TABLE dbname.reviews_hive (
REVIEWID int, 
PRODUCT int 
) 
COLUMN MAPPING 
(
key MAPPED BY (REVIEWID), 
summary:product MAPPED BY (PRODUCT) 
); 

(Ou)

SQL2:

CREATE HBASE TABLE dbname.reviews_hive (
REVIEWID int primary key not null, 
PRODUCT int 
) 
COLUMN MAPPING 
(
key MAPPED BY (REVIEWID), 
summary:product MAPPED BY (PRODUCT) 
); 

Error: [State: 42601][Code: -104]: An unexpected token "key" was found following "(". Expected tokens may include: "".. SQLCODE=-104, SQLSTATE=42601, DRIVER=3.68.61

Quelqu'un peut-il me aider à ce sujet?

Merci d'avance les gars.

Answer 1

Je suppose que vous êtes sur Big Insights 4.x. Avant BigInsights 4, l'interface SQL de Big SQL n'était disponible que dans BigSQL v1.

Quand je lance le script de test suivant (y compris vos deux CREATE Hbase TABLE) (j'ai couru cet exemple à la fois jsqsh et la ligne de commande db2), je reçois ces résultats:

\connect bigsql 
drop table if exists stack.issue3; 

create hbase table if not exists stack.issue3 (
f1 integer, 
f2 integer, 
f3 varchar(200), 
f4 integer 
) 
column mapping(
    key mapped by (f1, f2), 
    cf0:f3 mapped by (f3,f4) 
    encoding delimited 
    fields terminated by '\b' 
) 
default encoding binary 
; 

insert into stack.issue3 (f1,f2,f3,f4) values (0,0,'Detroit',0); 
insert into stack.issue3 (f1,f2,f3,f4) values (1,1,'Mt. Pleasant',1); 
insert into stack.issue3 (f1,f2,f3,f4) values (2,2,'Marysville',2); 
insert into stack.issue3 (f1,f2,f3,f4) values (3,3,'St. Clair',3); 
insert into stack.issue3 (f1,f2,f3,f4) values (4,4,'Port Huron',4); 

select * from stack.issue3; 

drop table if exists dbname.reviews_hive; 
CREATE HBASE TABLE if not exists dbname.reviews_hive (
     REVIEWID int, 
     PRODUCT int 
) 
COLUMN MAPPING (
key MAPPED BY (REVIEWID), 
summary:product MAPPED BY (PRODUCT) 
); 

insert into dbname.reviews_hive(reviewid,product) values (0,0); 
insert into dbname.reviews_hive(reviewid,product) values (1,1); 
insert into dbname.reviews_hive(reviewid,product) values (2,2); 
insert into dbname.reviews_hive(reviewid,product) values (3,3); 

select * from dbname.reviews_hive; 


drop table if exists dbname.reviews_hive1; 
CREATE HBASE TABLE if not exists dbname.reviews_hive1 (
     REVIEWID int primary key not null, 
     PRODUCT int 
) 
COLUMN MAPPING (
     key MAPPED BY (REVIEWID), 
     summary:product MAPPED BY (PRODUCT) 
); 

insert into dbname.reviews_hive1(reviewid,product) values (-1,1); 
insert into dbname.reviews_hive1(reviewid,product) values (-2,2); 
insert into dbname.reviews_hive1(reviewid,product) values (-3,3); 
insert into dbname.reviews_hive1(reviewid,product) values (-4,4); 

select * from dbname.reviews_hive1; 
\quit 

J'obtiens les résultats suivants:

jsqsh --autoconnect --input-file=./t2.sql --output-file=t2.out 
0 rows affected (total: 3.75s) 
0 rows affected (total: 1.63s) 
1 row affected (total: 0.29s) 
1 row affected (total: 0.27s) 
1 row affected (total: 0.15s) 
1 row affected (total: 0.25s) 
1 row affected (total: 0.26s) 
5 rows in results(first row: 0.22s; total: 0.23s) 
0 rows affected (total: 4.6s) 
0 rows affected (total: 1.65s) 
1 row affected (total: 0.29s) 
1 row affected (total: 0.15s) 
1 row affected (total: 0.25s) 
1 row affected (total: 0.15s) 
4 rows in results(first row: 0.18s; total: 0.18s) 
0 rows affected (total: 3.70s) 
0 rows affected (total: 1.66s) 
1 row affected (total: 0.30s) 
1 row affected (total: 0.26s) 
1 row affected (total: 0.16s) 
1 row affected (total: 0.15s) 
4 rows in results(first row: 0.18s; total: 0.18s) 

cat t2.out 
+----+----+--------------+----+ 
| F1 | F2 | F3   | F4 | 
+----+----+--------------+----+ 
| 0 | 0 | Detroit  | 0 | 
| 1 | 1 | Mt. Pleasant | 1 | 
| 2 | 2 | Marysville | 2 | 
| 3 | 3 | St. Clair | 3 | 
| 4 | 4 | Port Huron | 4 | 
+----+----+--------------+----+ 
+----------+---------+ 
| REVIEWID | PRODUCT | 
+----------+---------+ 
|  0 |  0 | 
|  1 |  1 | 
|  2 |  2 | 
|  3 |  3 | 
+----------+---------+ 
+----------+---------+ 
| REVIEWID | PRODUCT | 
+----------+---------+ 
|  -4 |  4 | 
|  -3 |  3 | 
|  -2 |  2 | 
|  -1 |  1 | 
+----------+---------+