ExtractSchemaColumns 2025.5.31.15¶
バンドル¶
com.snowflake.openflow.runtime | runtime-record-schema-nar
説明¶
提供された Record Reader を使用して FlowFile から記録スキーマ列を抽出し、 schema.columns 属性に書き込みます。
入力要件¶
REQUIRED
機密動的プロパティをサポート¶
false
プロパティ¶
プロパティ |
説明 |
|---|---|
終了列インデックス |
列を取得するスキーマ内の列のインデックスを指定します。 |
Record Reader |
受信データの読み取りに使用するController Serviceを指定します。 |
開始列インデックス |
列を取得するスキーマ内の列のインデックス (1 から始まる番号) を指定します。 |
リレーションシップ¶
名前 |
説明 |
|---|---|
failure |
FlowFile の記録スキーマが構成された入力形式から抽出できない場合、 FlowFile はこのリレーションシップにルーティングされます。 |
success |
FlowFiles 記録スキーマの抽出に成功した記録は、このリレーションシップにルーティングされます。 |
属性の書き込み¶
名前 |
説明 |
|---|---|
record.error.message |
この属性は、Reader が遭遇したエラーメッセージを提供します。 |
schema.columns |
この属性は、提供された RecordReader を使用して入力 FlowFile から抽出された列を提供します。 |