UpdateSnowflakeIcebergDatabase 2025.5.31.15¶

Bundle¶

com.snowflake.openflow.runtime | runtime-snowflake-processors-nar

Description¶

Met à jour la définition d’une table Snowflake Iceberg. Un schéma cible peut être déduit d’un RecordReader ou défini explicitement à l’aide du format suivant :{ « columns »: [ { « name »: « <column name> », « type »: « <iceberg data type> » }, … ]}où <type de données booléen> peut être l’un des types suivants :- type booléen primitif (« string », « int », « boolean »,…) - décimal avec une précision et une échelle données (« decimal(P,S) »)- {« type »: « list », « element »: <iceberg data type>}- {« type »: « map », « key »: <iceberg data type>, « value »: <iceberg data type>}- décimal(P,S) {« type »: « struct », « fields »:[<list of struct fields>] }

Balises¶

iceberg

Exigences en matière d’entrées¶

REQUIRED

Prend en charge les propriétés dynamiques sensibles¶

false

Propriétés¶

Propriété	Description
Add Column Strategy	La stratégie à utiliser lorsque le schéma entrant possède une colonne qui n’est pas présente dans la table existante
Alter Column Strategy	La stratégie à utiliser lorsqu’une colonne a un type de données différent dans le schéma entrant par rapport à la table existante
Connection Pool	Le pooling de connexions à utiliser pour se connecter à Snowflake
Schéma souhaité	La définition du schéma/de la table souhaitée
Drop Column Strategy	La stratégie à utiliser lorsque la table existante possède une colonne qui n’est pas présente dans le schéma entrant
Max Batch Size	Le nombre maximum de FlowFiles qui peuvent être traités en une seule exécution pour une table donnée.
Record Reader	Record Reader à utiliser pour obtenir le schéma souhaité
Nom de schéma	Le nom du schéma à mettre à jour
Temps d’expiration de la mémoire cache des métadonnées de la table	Délai en secondes après lequel l’entrée de cache sera supprimée
Nom de la table	Le nom de la table à mettre à jour
Table Schema Strategy	Spécifie comment obtenir la définition du schéma/de la table souhaité(e)
Utiliser la cache des métadonnées de table	Mettre en cache les métadonnées de la table au lieu de les lire directement depuis Snowflake

Relations¶

Nom	Description
failure	Le FlowFile est routé vers cette relation si la table ne peut pas être mise à jour
illegal alteration	Le FlowFile entrant est routé vers cette relation si la mise à jour nécessite une altération qui est configurée pour échouer
success	Le FlowFile est routé vers cette relation une fois que la table a été mise à jour avec succès
table non trouvée	Le FlowFile entrant est routé vers cette table si la table spécifiée n’existe pas.