arrowFlight - ClickHouse Documentation

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 サーバーから読み取る場合:

Query

SELECT * FROM arrowFlight('127.0.0.1:9005', 'sample_dataset') ORDER BY id;

Response

┌─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);

関連項目