ListDBFSDirectory 2025.5.31.15¶
バンドル¶
com.snowflake.openflow.runtime | runtime-databricks-processors-nar
説明¶
DBFS ディレクトリのファイル名をリストアップし、そのファイル名で新しい FlowFile を出力します。
入力要件¶
機密動的プロパティをサポート¶
false
プロパティ¶
プロパティ |
説明 |
|---|---|
DBFS ファイルパス |
DBFS ファイルパス 例: /ディレクトリ/file.txt |
Databricks クライアント |
Databricksクライアントサービス。 |
ディレクトリを含む |
FlowFiles にディレクトリが含まれます。 |
再帰ディレクトリリスト |
サブディレクトリ内のファイルを再帰的にリストアップします。 |
リレーションシップ¶
名前 |
説明 |
|---|---|
failure |
データブリックの障害関係 |
original |
処理が成功すると、元の FlowFile がこのリレーションシップにルーティングされます。 |
success |
データブリックスの成功関係 |
属性の書き込み¶
名前 |
説明 |
|---|---|
filename |
DBFS ファイルまたはディレクトリのベースファイル名。 |
path |
DBFS ファイルまたはディレクトリを含む親ディレクトリへのパス。 |
absolute.path |
DBFS ファイルまたはディレクトリへのフルパス。 |
dbfs.resourceType |
DBFS リソースのタイプ、「ファイル」または「ディレクトリ」。 |
dbfs.size |
DBFS ファイルのサイズ。 |
dbfs.lastModifiedTime |
UTC 時刻のエポックからのミリ秒単位での、 DBFS ファイルの最終更新時刻。 |
error.code |
エラーが発生した場合の SQL ステートメントのエラーコード。 |
error.message |
エラーが発生した場合の SQL ステートメントのエラーメッセージ。 |