Skip to main content
Il s’agit d’une extension de la fonction de table iceberg. Elle permet de traiter en parallèle, sur plusieurs nœuds d’un cluster spécifié, des fichiers issus d’Apache Iceberg. Sur l’initiateur, elle établit une connexion à tous les nœuds du cluster et répartit dynamiquement les fichiers. Sur le nœud worker, elle demande à l’initiateur la tâche suivante à traiter, puis l’exécute. Ce processus se répète jusqu’à ce que toutes les tâches soient terminées.

​
Syntaxe

​
Arguments

  • cluster_name — Nom du cluster utilisé pour constituer un ensemble d’adresses et de paramètres de connexion pour les serveurs distants et locaux.
  • La description de tous les autres arguments est identique à celle des arguments de la fonction de table iceberg équivalente.
  • Un paramètre facultatif extra_credentials peut être utilisé pour transmettre un role_arn afin d’activer le contrôle d’accès basé sur les rôles dans ClickHouse Cloud. Consultez Secure S3 pour les étapes de configuration.
Valeur renvoyée Une table de la structure spécifiée pour lire les données du cluster dans la table Iceberg spécifiée. Exemples

​
Colonnes virtuelles

  • _path — Chemin d’accès au fichier. Type : LowCardinality(String).
  • _file — Nom du fichier. Type : LowCardinality(String).
  • _size — Taille du fichier en octets. Type : Nullable(UInt64). Si la taille du fichier est inconnue, la valeur est NULL.
  • _time — Date et heure de la dernière modification du fichier. Type : Nullable(DateTime). Si cette information est inconnue, la valeur est NULL.
  • _etag — eTag du fichier. Type : LowCardinality(String). Si l’eTag est inconnu, la valeur est NULL.
Voir aussi
Dernière modification le 23 juillet 2026