Gestion des tables Apache Iceberg™¶

Exemple : Mettre à jour une table¶

Vous pouvez utiliser les instructions INSERT et UPDATE pour modifier les tables Iceberg gérées par Snowflake.

L’exemple suivant insère une nouvelle valeur dans une table Iceberg nommée store_sales, puis met à jour la colonne cola sur 1 si la valeur est actuellement -99.

INSERT INTO store_sales VALUES (-99);

UPDATE store_sales
  SET cola = 1
  WHERE cola = -99;

Copie sur écriture ou fusion sur lecture¶

Iceberg propose deux modes de configuration de la manière dont les moteurs de calcul gèrent les opérations de niveau ligne pour les tables gérées en externe. Snowflake prend en charge ces deux modes.

Le tableau suivant décrit les cas dans lesquels vous pourriez avoir besoin d’utiliser l’un ou l’autre mode :

Pour plus d’informations sur les modifications de niveau ligne pour Iceberg, voir Suppressions de niveau ligne dans la documentation d’Apache Iceberg.

Considérations et limites¶

Tenez compte des points suivants lorsque vous utilisez des suppressions de niveau ligne avec des tables Iceberg gérées en externe :

• Snowflake ne prend en charge que les suppressions par position.

• Pour obtenir les meilleures performances de lecture lorsque vous utilisez des suppressions de niveau ligne, procédez régulièrement au compactage et à la maintenance des tables afin de supprimer les anciens fichiers de suppression. Pour plus d’informations, voir Gestion des tables utilisant un catalogue externe.

• Les fonctions suivantes ne sont actuellement pas prises en charge lorsque vous utilisez des suppressions de niveau ligne :

  • Actualisation automatique

  • Création de vues matérialisées, d’optimisations de recherche ou de flux sur des tables dynamiques, des tables Iceberg dynamiques ou des tables Iceberg avec des suppressions par position existantes.

  • Tables dynamiques

  • Actualisation de l’instantané Iceberg avec suppressions par position sur des tables dynamiques, des tables Iceberg dynamiques ou des tables Iceberg comportant des vues matérialisées, des optimisations de recherche ou des flux actifs ou supprimés.

  • Optimisation de la recherche

  • Flux

Actualisation des métadonnées d’une table¶

L’exemple suivant actualise manuellement les métadonnées d’une table qui utilise un catalogue externe (par exemple, AWS Glue ou Delta). L’actualisation de la table permet de synchroniser la table en permanence en fonction des modifications apportées dans le catalogue distant.

Avec ce type de table Iceberg, il n’est pas nécessaire de spécifier un chemin d’accès au fichier de métadonnées dans la commande.

ALTER ICEBERG TABLE my_iceberg_table REFRESH;

Pour assurer la mise à jour automatique d’une table, vous pouvez paramétrer l”actualisation automatique. Utilisez la commande ALTER ICEBERG TABLE.

Par exemple :

ALTER ICEBERG TABLE my_iceberg_table SET AUTO_REFRESH = TRUE;

Actualisation des métadonnées d’une table créée à partir de fichiers Iceberg¶

L’exemple suivant actualise manuellement une table créée à partir de fichiers de métadonnées Iceberg dans un emplacement de stockage cloud externe, en spécifiant le chemin d’accès relatif à un fichier de métadonnées sans barre oblique (/). Le fichier de métadonnées définit les données de la table après actualisation.

ALTER ICEBERG TABLE my_iceberg_table REFRESH 'metadata/v1.metadata.json';