ListDBFSDirectory 2025.3.28.13-SNAPSHOT¶
BUNDLE¶
com.snowflake.openflow.runtime | runtime-databricks-processors-nar
DESCRIPTION¶
List file names in a DBFS directory and output a new FlowFile with the filename.
INPUT REQUIREMENT¶
Supports Sensitive Dynamic Properties¶
false
PROPERTIES¶
Property |
Description |
---|---|
DBFS File Path |
DBFS file path e.g. /directory/file.txt |
Databricks Client |
Databricks Client Service. |
Include Directories |
Include directories in FlowFiles produced. |
Recursive Directory Listing |
Recursively list files in sub directories. |
RELATIONSHIPS¶
NAME |
DESCRIPTION |
---|---|
original |
The original FlowFile is routed to this relationship when processing is successful. |
failure |
Databricks failure relationship |
success |
Databricks success relationship |
WRITES ATTRIBUTES¶
NAME |
DESCRIPTION |
---|---|
filename |
Base filename of the DBFS file or directory. |
path |
Path to parent directory containing the DBFS file or directory. |
absolute.path |
Full path to the DBFS file or directory. |
dbfs.resourceType |
The type of resource, ‘file’ or ‘directory’ of the DBFS resource. |
dbfs.size |
The size of the DBFS file. |
dbfs.lastModifiedTime |
The last modified time of the DBFS file, in milliseconds since epoch in UTC time. |
error.code |
The error code for the SQL statement if an error occurred. |
error.message |
The error message for the SQL statement if an error occurred. |