ExtractSchemaColumns 2025.5.31.15¶
捆绑包¶
com.snowflake.openflow.runtime | runtime-record-schema-nar
描述¶
使用提供的记录读取器从 FlowFile 中提取记录架构列，并将其写入到 schema.columns 属性。
输入要求¶
REQUIRED
支持敏感的动态属性¶
false
属性¶
属性 |
描述 |
|---|---|
结束列索引 |
指定架构中列的索引，应将列提取到架构中。 |
记录读取器 |
指定用于读取传入数据的控制器服务 |
开始列索引 |
指定架构中列的索引（从 1 开始编号），应从架构中提取列。 |
关系¶
名称 |
描述 |
|---|---|
failure |
如果无法从配置的输入格式中提取 FlowFile 的记录架构，则 FlowFile 将路由到此关系 |
success |
从中成功提取记录架构的 FlowFiles 将会路由到此关系 |
写入属性¶
名称 |
描述 |
|---|---|
record.error.message |
此属性提供了操作失败时读取器遇到的错误消息。 |
schema.columns |
此属性提供了使用提供的 RecordReader 从输入 FlowFile 中提取的列。 |