ExtractSchemaColumns 2025.5.31.15¶
Bundle¶
com.snowflake.openflow.runtime | runtime-record-schema-nar
Description¶
Extrait les colonnes du schéma d’enregistrement du FlowFile à l’aide du Record Reader fourni et les écrit dans l’attribut schema.columns.
Exigences en matière d’entrées¶
REQUIRED
Prend en charge les propriétés dynamiques sensibles¶
false
Propriétés¶
Propriété |
Description |
|---|---|
Index de fin de colonne |
Spécifie l’index de la colonne dans le schéma vers laquelle les colonnes doivent être prises. |
Record Reader |
Spécifie le Controller Service à utiliser pour la lecture des données entrantes |
Index de la colonne de départ |
Spécifie l’index de la colonne (numérotée à partir de 1) dans le schéma à partir duquel les colonnes doivent être extraites. |
Relations¶
Nom |
Description |
|---|---|
failure |
Si le schéma d’enregistrement d’un FlowFilene peut pas être extrait du format d’entrée configuré, le FlowFile sera routé vers cette relation |
success |
Les FlowFiles dont les schémas d’enregistrement ont été extraits avec succès seront routés vers cette relation |
Écrit les attributs¶
Nom |
Description |
|---|---|
record.error.message |
Cet attribut fournit, en cas d’échec, le message d’erreur rencontré par le lecteur. |
schema.columns |
Cet attribut fournit des colonnes extraites de l’entrée du FlowFile à l’aide du RecordReader fourni. |