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

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

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

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

Наличие внешней таблицы можно проверить, как описано в разделе Проверка наличия внешней таблицы.

Пример

CREATE UPLOAD EXTERNAL TABLE marketing.sales_ext_upload (
  id BIGINT,
  transaction_date TIMESTAMP,
  product_code VARCHAR(256),
  product_units BIGINT,
  store_id BIGINT,
  description VARCHAR(256)
)
LOCATION 'kafka_brokers://10.129.0.22:9092,10.129.0.123:9092/sales_in'
FORMAT 'AVRO'
MESSAGE_LIMIT 1000