Создание внешней таблицы загрузки
Чтобы создать внешнюю таблицу загрузки в логической БД, выполните запрос CREATE UPLOAD EXTERNAL TABLE. При успешном выполнении запроса внешняя таблица загрузки появляется в логической схеме данных.
Совет: для удобства разделения таблиц загрузки и выгрузки рекомендуется задавать имя таблицы, указывающее на ее тип (например, transactions_ext_upload
или transactions_ext_download
).
Примечание: внешняя таблица представляет собой декларацию источника данных и формата загрузки данных и не хранит сами данные.
Наличие внешней таблицы можно проверить, как описано в разделе Проверка наличия внешней таблицы.
Пример
-- выбор базы данных sales по умолчанию
USE sales
-- создание внешней таблицы загрузки
CREATE UPLOAD EXTERNAL TABLE sales.sales_ext_upload (
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'
FORMAT 'AVRO'
MESSAGE_LIMIT 1000