クラスター内の複数のノードで、指定したパスに一致するファイルを同時に処理できるようにします。イニシエーターはワーカーノードへの接続を確立し、ファイルパス内のグロブを展開して、ファイル読み取りタスクをワーカーノードに割り当てます。各ワーカーノードは、次に処理するファイルをイニシエーターに問い合わせ、すべてのタスクが完了する (つまり、すべてのファイルが読み込まれる) までこれを繰り返します。
この関数が_正しく_動作するのは、最初に指定したパスに一致するファイルの集合がすべてのノードで同一であり、それらの内容がノード間で一貫している場合に限られます。
これらのファイルがノードごとに異なる場合、戻り値は事前には決定できず、ワーカーノードがイニシエーターにタスクを要求する順序に依存します。fileCluster(cluster_name, path[, format, structure, compression_method])
| Argument | Description |
|---|
cluster_name | リモートサーバーおよびローカルサーバーへのアドレスのセットと接続パラメーターを構築する際に使用するクラスター名。 |
path | user_files_path からのファイルへの相対パスです。ファイルパスでは グロブ もサポートされます。 |
format | ファイルの フォーマット。型: String。 |
structure | 'UserID UInt64, Name String' 形式のテーブル構造です。カラム名と型を決定します。型: String。 |
compression_method | 圧縮方式。サポートされている圧縮タイプは gz、br、xz、zst、lz4、bz2 です。 |
my_cluster という名前のクラスターがあり、設定 user_files_path の値が次のとおりであるとします。
$ grep user_files_path /etc/clickhouse-server/config.xml
<user_files_path>/var/lib/clickhouse/user_files/</user_files_path>
user_files_path に test1.csv と test2.csv があり、それらの内容がすべてのノードで同一である場合:
$ cat /var/lib/clickhouse/user_files/test1.csv
1,"file1"
11,"file11"
$ cat /var/lib/clickhouse/user_files/test2.csv
2,"file2"
22,"file22"
INSERT INTO TABLE FUNCTION file('file1.csv', 'CSV', 'i UInt32, s String') VALUES (1,'file1'), (11,'file11');
INSERT INTO TABLE FUNCTION file('file2.csv', 'CSV', 'i UInt32, s String') VALUES (2,'file2'), (22,'file22');
fileCluster テーブル関数を使用して test1.csv と test2.csv のデータ内容を読み込みます。
SELECT * FROM fileCluster('my_cluster', 'file{1,2}.csv', 'CSV', 'i UInt32, s String') ORDER BY i, s
┌──i─┬─s──────┐
│ 1 │ file1 │
│ 11 │ file11 │
└────┴────────┘
┌──i─┬─s──────┐
│ 2 │ file2 │
│ 22 │ file22 │
└────┴────────┘
