Интеграция BigSQL-HBase

Question

Я новичок в BigSQL. Я узнал, что HBase может быть интегрирован с BigSQL. Я пытался выполнить команды создания BigSQL-HBase после и до создания таблиц HBase, но я получаю сообщение об ошибке, которое упоминается ниже.

SQL1:

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

(Или же)

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)
);

Ошибка: [Состояние: 42601][Код: -104]: неожиданный токен "ключ" был найден после "(". Ожидаемые токены могут включать: "".. SQLCODE=-104, SQLSTATE=42601, DRIVER=3.68.61

Может ли кто-нибудь помочь мне в этом?

Заранее спасибо, ребята.

Answer 1

Я предполагаю, что вы находитесь на Big Insights 4.x. До BigInsights 4 интерфейс SQL Big SQL был доступен только в BigSQL v1.

Когда я запускаю следующий тестовый скрипт (включая два ваших оператора CREATE HBASE TABLE) (я запускал этот пример как через jsqsh, так и через командную строку db2), я получаю следующие результаты:

\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

Я получаю следующие результаты:

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 |
+----------+---------+