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.