icebergCluster テーブル関数
これは iceberg テーブル関数への拡張です。
指定されたクラスター内の多数のノードから、Apache Iceberg のファイルを並列に処理することを可能にします。イニシエーターはクラスター内のすべてのノードへの接続を作成し、各ファイルを動的に配信します。ワーカーノードでは、イニシエーターに次の処理タスクを尋ねて処理し、すべてのタスクが完了するまでこれを繰り返します。
構文
引数
cluster_name
— リモートおよびローカルサーバーへのアドレスと接続パラメータのセットを構築するために使用されるクラスターの名前。- 他のすべての引数の説明は、同等の iceberg テーブル関数の引数の説明と一致します。
返される値
指定されたIcebergテーブルからクラスターのデータを読み取るための指定された構造のテーブル。
例
仮想カラム
_path
— ファイルへのパス。型:LowCardinality(String)
。_file
— ファイルの名前。型:LowCardinality(String)
。_size
— ファイルのサイズ(バイト単位)。型:Nullable(UInt64)
。ファイルサイズが不明な場合、値はNULL
です。_time
— ファイルの最終更新時刻。型:Nullable(DateTime)
。時間が不明な場合、値はNULL
です。_etag
— ファイルのetag。型:LowCardinality(String)
。etagが不明な場合、値はNULL
です。
関連情報