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 — Basic HTTP 認証に使用するユーザー名です。String。
  • password — Basic HTTP 認証に使用するパスワードです。String。

username と password が指定されていない場合、認証は使用されません (これは Arrow Flight サーバーが認証なしのアクセスを許可している場合にのみ機能します) 。

この関数は named collections にも対応しています。サポートされるパラメータの一覧については、ArrowFlight table engine を参照してください。

戻り値

リモートのデータセットを表すテーブルオブジェクトです。スキーマは Arrow Flight サーバーから推論されます。

設定

  • arrow_flight_request_descriptor_type — データセット名を Flight サーバーに送信する方法を制御します。値は path (デフォルト) または command です。詳細は ArrowFlight table engine を参照してください。

例

リモートの 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);

named collection を使用する場合:

SELECT * FROM arrowFlight(named_collection_name);

関連項目

Navigation