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.

Tags¶

avro, csv, freeform, generic, json, record, schema, text, xml

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.