Skip to content
ClickHouse Docs
ClickHouse DocsClickHouse Docs
49.6kGet Started

arrowFlight

View as MarkdownEdit this pageReport an issueSet up docs MCP

Позволяет читать и записывать данные, доступные через сервер Apache Arrow Flight.

Синтаксис

arrowFlight('host:port', 'dataset_name' [, 'username', 'password'])

Аргументы

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

Если username и password не указаны, аутентификация не используется (это работает, только если сервер Arrow Flight разрешает неаутентифицированный доступ).

Функция также поддерживает named collections — список поддерживаемых параметров см. в разделе движок таблицы ArrowFlight.

Возвращаемое значение

Объект таблицы, представляющий удалённый набор данных. Схема определяется автоматически на сервере Arrow Flight.

Настройки

  • arrow_flight_request_descriptor_type — Управляет тем, как имя набора данных отправляется на сервер Flight. Значения: path (по умолчанию) или command. Подробности см. в разделе движок таблицы ArrowFlight.

Примеры

Чтение с удалённого сервера Arrow Flight:

Querysql
SELECT * FROM arrowFlight('127.0.0.1:9005', 'sample_dataset') ORDER BY id;
Responsetext
┌─id─┬─name────┬─value─┐
│  1 │ foo     │ 42.1  │
│  2 │ bar     │ 13.3  │
│  3 │ baz     │ 77.0  │
└────┴─────────┴───────┘

Вставка данных на удалённый сервер Arrow Flight:

INSERT INTO FUNCTION arrowFlight('127.0.0.1:9005', 'sample_dataset') VALUES (4, 'qux', 99.9);

Использование именованной коллекции:

SELECT * FROM arrowFlight(named_collection_name);

См. также

Navigation