ListUnityCatalogDirectory 2025.3.28.13-SNAPSHOT¶
BUNDLE¶
com.snowflake.openflow.runtime | runtime-databricks-processors-nar
DESCRIPTION¶
List file names in a Unity Catalog directory and output a new FlowFile with the filename.
INPUT REQUIREMENT¶
Supports Sensitive Dynamic Properties¶
false
PROPERTIES¶
Property |
Description |
|---|---|
Databricks Client |
Databricks Client Service. |
Include Directories |
Include directories in FlowFiles produced. |
Recursive Directory Listing |
Recursively list files in sub directories. |
Unity Catalog Directory Path |
Unity Catalog directory path e.g. /Volumes/catalog/schema/volume_name/directory |
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 Unity Catalog file or directory. |
path |
Path to parent directory containing the Unity Catalog file or directory. |
absolute.path |
Full path to the Unity Catalog file or directory. |
uc.resourceType |
The type of resource, ‘file’ or ‘directory’ of the Unity Catalog resource. |
uc.size |
The size of the Unity Catalog file. |
uc.lastModifiedTime |
The last modified time of the Unity Catalog 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. |