ExtractSchemaColumns 2025.5.31.15¶
Bundle¶
com.snowflake.openflow.runtime | runtime-record-schema-nar
Beschreibung¶
Extrahiert die Spalten des Datensatzschemas mit Hilfe des mitgelieferten Record Reader aus dem FlowFile und schreibt sie in das Attribut schema.columns
.
Eingabeanforderung¶
REQUIRED
Unterstützt sensible dynamische Eigenschaften¶
false
Eigenschaften¶
Eigenschaft |
Beschreibung |
---|---|
End Column Index |
Gibt den Index der Spalte im Schema an, zu der Spalten zugeordnet werden sollen. |
Record Reader |
Gibt den Controller Service an, der zum Lesen eingehender Daten verwendet werden soll |
Start Column Index |
Gibt den Index der Spalte (nummeriert ab 1) im Schema an, aus der Spalten übernommen werden sollen. |
Beziehungen¶
Name |
Beschreibung |
---|---|
failure |
Wenn das Datensatzschema eines FlowFile nicht aus dem konfigurierten Eingabeformat extrahiert werden kann, wird das FlowFile an diese Beziehung weitergeleitet. |
success |
FlowFiles, deren Datensatzschemas erfolgreich extrahiert wurden, werden an diese Beziehung weitergeleitet. |
Schreibt Attribute¶
Name |
Beschreibung |
---|---|
record.error.message |
Dieses Attribut gibt im Falle eines Fehlers die Fehlermeldung an, die der Reader erhalten hat. |
schema.columns |
Dieses Attribut liefert Spalten, die aus dem Eingabe-FlowFile unter Verwendung des bereitgestellten RecordReader extrahiert wurden. |