Skip to main content
Skip to main content
Edit this page

Arrow Flight

The Arrow Flight table engine enables ClickHouse to query remote datasets via the Apache Arrow Flight protocol. This integration allows ClickHouse to fetch data from external Flight-enabled servers in a columnar Arrow format with high performance.

Creating a Table​

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

Engine Parameters

  • host:port — Address of the remote Arrow Flight server.
  • dataset_name — Identifier of the dataset on the Flight server.

Usage Example​

This example shows how to create a table that reads data from a remote Arrow Flight server:

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

Query the remote data as if it were a local table:

SELECT * FROM remote_flight_data ORDER BY id;

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

Notes​

  • The schema defined in ClickHouse must match the schema returned by the Flight server.
  • This engine is suitable for federated queries, data virtualization, and decoupling storage from compute.

See Also​