CREATE DOWNLOAD EXTERNAL TABLE
Содержание раздела
Запрос позволяет создать внешнюю таблицу выгрузки в логической базе данных.
В ответе возвращается:
- пустой объект ResultSet при успешном выполнении запроса;
- исключение при неуспешном выполнении запроса.
После успешного выполнения запроса можно выполнять запросы INSERT INTO download_external_table на выгрузку данных. Подробнее о порядке выполнения действий для выгрузки данных см. в разделе Выгрузка данных.
Изменение внешней таблицы недоступно. Для замены внешней таблицы необходимо удалить ее и создать новую.
Синтаксис
CREATE DOWNLOAD EXTERNAL TABLE [db_name.]ext_table_name(
column_name_1 datatype_1,
column_name_2 datatype_2,
column_name_3 datatype_3
)
LOCATION receiver_URI
FORMAT 'AVRO'
[CHUNK_SIZE records_per_message]
Параметры:
db_name
-
Имя логической базы данных, в которой создается внешняя таблица. Опционально, если выбрана логическая БД, используемая по умолчанию.
ext_table_name
-
Имя создаваемой внешней таблицы. Должно быть уникально среди всех логических сущностей логической БД, а также должно удовлетворять другим условиям, перечисленным в секции Ограничения. Чтобы можно было различать разные типы внешних таблиц между собой, рекомендуется давать им имена, указывающие на тип таблицы, например
sales_ext_download
. column_name_N
-
Имя столбца таблицы. Должно удовлетворять условиям, перечисленным в секции Ограничения.
datatype_N
-
Тип данных столбца
column_name_N
. Возможные значения см. в разделе Логические типы данных. receiver_URI
-
Путь к топику Kafka (см. Формат пути к топику Kafka).
records_per_message
-
Максимальное количество записей, выгружаемых из хранилища в одном сообщении топика Каfka.
Ограничения
- Выполнение запроса недоступно в сервисной базе данных
INFORMATION_SCHEMA
. - Имена таблицы и ее столбцов должны начинаться с латинской буквы, после первого символа могут следовать латинские буквы, цифры и символы подчеркивания в любом порядке.
- Таблица и ее столбцы не могут иметь имена, перечисленные в разделе Зарезервированные слова.
Пример
CREATE DOWNLOAD EXTERNAL TABLE marketing.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