topic Re: Delta Live Tables: How does it identify new files? in Data Engineering

Delta Live Tables: How does it identify new files?

dbuschi — Wed, 13 Nov 2024 05:43:16 GMT

Hi,
I'm importing large numbers of parquet files (ca 5200 files per day, they each land in a separate folder) into Azure ADLS storage.
I have a DLT streaming table reading from the root folder.
I noticed a massive spike in storage account costs due to file system reads.
Questions: How does DLT identify newly arriving files? Does it always have to monitor the entire folder including all historical files?
Are there any design patterns to resolve this (i.e regarding folder structure, archiving of processed files)?
Many thanks for your help!

Re: Delta Live Tables: How does it identify new files?

SparkJun — Wed, 13 Nov 2024 06:02:11 GMT

Please refer to the autoloader for details https://learn.microsoft.com/en-us/azure/databricks/ingestion/cloud-object-storage/auto-loader/ You can use autoloader in DLT to detect new files. Our document also mentions the file name patterns that work with the autoloader.

Re: Delta Live Tables: How does it identify new files?

dbuschi — Wed, 20 Nov 2024 10:30:13 GMT

To resolve the issue of excessive directory scanning, I have changed the folder structure to separate historical files from current files and reduce the number of folders and files that the Databrick process monitors.