Создание внешней таблицы выгрузки
Чтобы создать внешнюю таблицу выгрузки в логической БД, выполните запрос CREATE DOWNLOAD EXTERNAL TABLE. При успешном выполнении запроса внешняя таблица загрузки появляется в логической схеме данных.
Для удобства разделения таблиц выгрузки и загрузки рекомендуется задавать имя таблицы, указывающее на ее тип (например, transactions_ext_download
или transactions_ext_upload
).
Внешняя таблица представляет собой декларацию приемника данных и формата выгрузки данных и не хранит сами данные.
Наличие внешней таблицы можно проверить, как описано в разделе Проверка наличия внешней таблицы.
Пример
-- выбор базы данных sales по умолчанию
USE sales;
-- создание внешней таблицы выгрузки
CREATE DOWNLOAD EXTERNAL TABLE sales.sales_ext_download (
id INT,
transaction_date TIMESTAMP,
product_code VARCHAR(256),
product_units INT,
store_id INT,
description VARCHAR(256)
)
LOCATION 'kafka://zk1:2181,zk2:2181,zk3:2181/sales_out'
FORMAT 'AVRO'
CHUNK_SIZE 1000;