Как мне сделать так, чтобы результат запроса был разделен на входные данные? - PullRequest
Новая
       60

Как мне сделать так, чтобы результат запроса был разделен на входные данные?

2 голосов
/ 05 апреля 2019

Я новичок в улье, поэтому основной вопрос: как мне создать запрос таким образом, чтобы результат этого запроса был разделен определенным образом?

Например: 

CREATE TABLE IF NOT EXISTS tbl_x (
 x SMALLINT,
 y FLOAT)
PARTITIONED BY (id SMALLINT)
ROW FORMAT DELIMITED
FIELDS TERMINATED BY ','
STORED AS ORC;

INSERT INTO TABLE `tbl_x` 
VALUES (1, 1, 1.0),
       (1, 1, 2.0),
       (1, 2, 3.0),
       (1, 2, 4.0),
       (2, 1, 5.0),
       (2, 1, 6.0),
       (2, 2, 7.0),
       (2, 2, 8.0);

CREATE TABLE tbl_y AS SELECT `id`, `x`, SUM(`y`) AS `y_sum`
FROM `tbl_x`
GROUP BY `id`, `x`;

В этом примере я бы хотел, чтобы tbl_y тоже был разбит на части.

Попытка этого не работает: 

CREATE TABLE tbl_y AS SELECT `id`, `x`, SUM(`y`) AS `y_sum`
FROM `tbl_x`
GROUP BY `id`, `x` PARTITIONED BY (id SMALLINT);

В чем тут хитрость? Должен ли я сначала определить секционированную таблицу и вставить результаты в?

1 Ответ

2 голосов
/ 05 апреля 2019

Да, вам следует создать разделенную таблицу отдельно.Создание многораздельной таблицы как выбор (CTAS) не поддерживается. 

CREATE TABLE tbl_y(x smallint,y_sum double)
partitioned by (id smallint)
STORED AS ORC;

Если схема таблицы такая же, вы можете использовать CREATE LIKE : 

CREATE TABLE tbl_y like tbl_x;

Вы также можете использовать DISTRIBUTE BY для равномерного распределения данных между редукторами, см. Также этот ответ: https://stackoverflow.com/a/38475807/2700344

insert overwrite table tbl_y partition(id)
select id, x, SUM(y) AS y_sum
fromtbl_x
group by id, x 
distribute by id, FLOOR(RAND()*100.0)%20;
...