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 身份验证的用户名。String。
• password — 用于基本 HTTP 身份验证的密码。String。

​

命名集合

CREATE TABLE remote_flight_data
    ENGINE = ArrowFlight(named_collection_name);

​

设置

• arrow_flight_request_descriptor_type — 控制向 Flight 服务器发送数据集名称的方式。可能的值：path (默认值，以 PATH 描述符形式发送) 或 command (以 CMD 描述符形式发送，内容为 SELECT * FROM <dataset>) 。对于需要 SQL 命令的 Flight 服务器 (例如 Dremio) ，请使用 command。

• 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 服务器 返回的 schema 一致。
• 如果省略列，则会自动根据远程 server 推断 schema。
• 支持读取 (SELECT) 和写入 (INSERT) 。
• arrow_flight_request_descriptor_type 设置用于控制将数据集名称作为 PATH 描述符发送，还是作为封装 SELECT * 查询的 CMD 描述符发送。

​

另请参见

• arrowFlight 表函数
• Arrow Flight 接口
• Apache Arrow Flight SQL
• ClickHouse 中的 Arrow 格式集成