Prise en charge des tables et schéma¶

Ce chapitre couvre les types de tables, les types de données et les capacités de schéma pris en charge par Snowpipe Streaming.

Prise en charge de tables Apache Iceberg™¶

Snowpipe Streaming prend en charge l’ingestion dans des tables Apache Iceberg™ gérées par Snowflake, y compris les tables Iceberg v2 et Iceberg v3. Pour plus d’informations, voir Architecture hautes performances de Snowpipe Streaming avec les tables Apache Iceberg™.

Évolution du schéma¶

Snowpipe Streaming prend en charge l’évolution automatique du schéma de la table. Lorsque cette option est activée, Snowflake peut ajouter automatiquement de nouvelles colonnes détectées dans le flux entrant et abandonner les contraintes NOTNULL pour prendre en charge de nouveaux modèles de données. Pour plus d’informations, consultez Évolution du schéma de la table.

Limites de l’évolution des schémas :

Prise en charge exclusive pour les tables standard de Snowflake. Les tables externes et les tables Apache Iceberg™ ne sont pas prises en charge.
La précision, l’échelle ou la longueur des colonnes existantes ne peut pas être augmentée automatiquement.
L’évolution du schéma n’est pas prise en charge pour les types de données structurées. Cependant, les nouvelles colonnes qui contiennent des types structurés sont déduites comme étant des VARIANT.

Opérations à insertion uniquement¶

L” API est actuellement limité à l’insertion de lignes. Pour modifier, supprimer ou combiner des données, écrivez les enregistrements « bruts « dans une ou plusieurs tables mises en zone de préparation. Fusionnez, joignez ou transformez les données en utilisant des pipelines de données continus pour insérer les données modifiées dans les tableaux de reporting de destination.

Types de données Java pris en charge¶

Le tableau suivant résume les types de données Java pris en charge pour l’ingestion dans les colonnes Snowflake :


Type de colonne Snowflake	Type de données Java autorisées
CHAR VARCHAR	Chaîne les types de données primitifs (int, boolean, char, …) BigInteger, BigDecimal
BINARY	octet[] Chaîne (encodée en hexadécimal)
NUMBER	Types numériques (BigInteger, BigDecimal, byte, int, double, …) Chaîne
FLOAT	Types numériques (BigInteger, BigDecimal, byte, int, double, …) Chaîne
BOOLEAN	booléen Types numériques (BigInteger, BigDecimal, byte, int, double, …) Chaîne Voir détails de la conversion booléenne.
TIME	java.time.LocalTime java.time.OffsetTime Chaîne Temps stocké en entier `HH24:MI:SS.FFTZH:TZM` (par exemple, `20:57:01.123456789+07:00`) `HH24:MI:SS.FF` (par exemple, `20:57:01.123456789`) `HH24:MI:SS` (par exemple, `20:57:01`) `HH24:MI` (par exemple, `20:57`)
DATE	java.time.LocalDate java.time.LocalDateTime java.time.OffsetDateTime java.time.ZonedDateTime java.time.Instant Chaîne Date stockée en entier `YYYY-MM-DD` (par exemple, `2013-04-28`) `YYYY-MM-DDTHH24:MI:SS.FFTZH:TZM` (par exemple, `2013-04-28T20:57:01.123456789+07:00`) `YYYY-MM-DDTHH24:MI:SS.FF` (par exemple, `2013-04-28T20:57:01.123456`) `YYYY-MM-DDTHH24:MI:SS` (par exemple, `2013-04-28T20:57:01`) `YYYY-MM-DDTHH24:MI` (par exemple, `2013-04-28T20:57`) `YYYY-MM-DDTHH24:MI:SSTZH:TZM` (par exemple, `2013-04-28T20:57:01-07:00`) `YYYY-MM-DDTHH24:MITZH:TZM` (par exemple, `2013-04-28T20:57-07:00`)
TIMESTAMP_NTZ TIMESTAMP_LTZ TIMESTAMP_TZ	java.time.LocalDate java.time.LocalDateTime java.time.OffsetDateTime java.time.ZonedDateTime java.time.Instant Chaîne Horodatage stocké en entier `YYYY-MM-DD` (par exemple, `2013-04-28`) `YYYY-MM-DDTHH24:MI:SS.FFTZH:TZM` (par exemple, `2013-04-28T20:57:01.123456789+07:00`) `YYYY-MM-DDTHH24:MI:SS.FF` (par exemple, `2013-04-28T20:57:01.123456`) `YYYY-MM-DDTHH24:MI:SS` (par exemple, `2013-04-28T20:57:01`) `YYYY-MM-DDTHH24:MI` (par exemple, `2013-04-28T20:57`) `YYYY-MM-DDTHH24:MI:SSTZH:TZM` (par exemple, `2013-04-28T20:57:01-07:00`) `YYYY-MM-DDTHH24:MITZH:TZM` (par exemple, `2013-04-28T20:57-07:00`)
VARIANT ARRAY	Chaîne (doit être un JSON valide) les types de données primitifs et leurs tableaux BigInteger, BigDecimal java.time.LocalTime java.time.OffsetTime java.time.LocalDate java.time.LocalDateTime java.time.OffsetDateTime java.time.ZonedDateTime java.util.Map<String, T> où T est un type VARIANT valide T[] où T est un type VARIANT valide Liste<T> où T est un type VARIANT valide
OBJECT	Chaîne (doit être un objet JSON valide) Map<String, T> où T est un type de variante valide
GEOGRAPHY	Pris en charge
GEOMETRY	Pris en charge