Создание внешней таблицы загрузки

Чтобы создать внешнюю таблицу загрузки в логической БД, выполните запрос CREATE UPLOAD EXTERNAL TABLE (см. пример ниже). При успешном выполнении запроса в логической схеме данных появляется новая внешняя таблица загрузки. Проверить наличие внешней таблицы можно в дереве объектов SQL-клиента (см. рисунок ниже).

Совет: для удобства разделения таблиц загрузки и выгрузки рекомендуется задавать имя таблицы, указывающее на ее тип (например, transactions_ext_upload или transactions_ext_download).

Примечание: внешняя таблица представляет собой декларацию источника данных и формата загрузки данных и не хранит сами данные.

На рисунке ниже показан фрагмент дерева объектов SQL-клиента, которое содержит внешнюю таблицу загрузки sales_ext_upload.

Внешняя таблица загрузки в дереве объектов

Пример

-- выбор базы данных sales по умолчанию
USE sales

-- создание внешней таблицы загрузки
CREATE UPLOAD EXTERNAL TABLE sales_ext_upload (
  identification_number 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