ExtractSchemaColumns 2025.5.31.15¶
Bundle¶
com.snowflake.openflow.runtime | runtime-record-schema-nar
Description¶
Extracts the record schema columns from the FlowFile using the supplied Record Reader and writes it to the schema.columns attribute.
Input Requirement¶
REQUIRED
Supports Sensitive Dynamic Properties¶
false
Properties¶
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. |
Relationships¶
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 |
Writes attributes¶
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. |