ExtractSchemaColumns 2025.10.9.21¶

Bundle¶

com.snowflake.openflow.runtime | runtime-record-schema-nar

Extracts the record schema columns from the FlowFile using the supplied Record Reader and writes it to the schema.columns attribute.

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

REQUIRED

false

Property	Description
End Column Index	Specifies index of the column in schema to which columns should be taken.
Record Reader	Specifies the Controller Service to use for reading incoming data
Start Column Index	Specifies index of the column (numbered from 1) in schema from which columns should be taken.

Name	Description
failure	If a FlowFile’s record schema cannot be extracted from the configured input format, the FlowFile will be routed to this relationship
success	FlowFiles whose record schemas are successfully extracted will be routed to this relationship

Name	Description
record.error.message	This attribute provides on failure the error message encountered by the Reader.
schema.columns	This attribute provides columns extracted from the input FlowFile using the provided RecordReader.