Движок таблицы ArrowFlight

​

Создание таблицы

CREATE TABLE [IF NOT EXISTS] [db.]table_name (name1 [type1], name2 [type2], ...)
    ENGINE = ArrowFlight('host:port', 'dataset_name' [, 'username', 'password']);

• host:port — Адрес удалённого сервера Arrow Flight. Если порт не указан, используется порт по умолчанию 8815. String.
• dataset_name — Идентификатор набора данных на сервере Flight (используется как дескриптор PATH или в запросе SELECT * в зависимости от настройки arrow_flight_request_descriptor_type). String.
• username — Имя пользователя для HTTP-аутентификации Basic. String.
• password — Пароль для HTTP-аутентификации Basic. String.

​

Именованные коллекции

CREATE TABLE remote_flight_data
    ENGINE = ArrowFlight(named_collection_name);

​

Настройки

• arrow_flight_request_descriptor_type — Определяет, как имя набора данных отправляется на сервер Flight. Возможные значения: path (по умолчанию, отправляется как дескриптор PATH) или command (отправляется как дескриптор CMD с SELECT * FROM <dataset>). Используйте command для серверов Flight, которые ожидают SQL-команды (например, Dremio).
• arrow_flight_request_timeout_sec — Тайм-аут в секундах для одного запроса Arrow Flight, по умолчанию 300. Он распространяется на весь запрос целиком: для SELECT это весь поток результатов, а не только ожидание первого батча записей. 0 означает отсутствие тайм-аута; в этом случае сервер Flight, принявший запрос, но так и не ответивший на него, блокирует выполнение запроса до закрытия соединения.

​

Пример использования

CREATE TABLE remote_flight_data
(
    id UInt32,
    name String,
    value Float64
) ENGINE = ArrowFlight('127.0.0.1:9005', 'sample_dataset');

SELECT * FROM remote_flight_data ORDER BY id;

┌─id─┬─name────┬─value─┐
│  1 │ foo     │ 42.1  │
│  2 │ bar     │ 13.3  │
│  3 │ baz     │ 77.0  │
└────┴─────────┴───────┘

INSERT INTO remote_flight_data VALUES (4, 'qux', 99.9);

​

Примечания

• Если в операторе CREATE TABLE указаны столбцы, они должны соответствовать схеме, возвращаемой сервером Flight.
• Если столбцы не указаны, схема автоматически определяется на основе данных удалённого сервера.
• Поддерживаются как чтение (SELECT), так и запись (INSERT).
• Параметр arrow_flight_request_descriptor_type определяет, будет ли имя набора данных отправлено как дескриптор PATH или как дескриптор CMD, содержащий запрос SELECT *.

​

См. также

• Табличная функция arrowFlight
• Интерфейс Arrow Flight
• Apache Arrow Flight SQL
• Интеграция формата Arrow в ClickHouse