How does AutoLoader works when triggered via Azure Data Factory?

[zll_0091]

Hi,

I am currently creating an AutoLoader in databricks and will be using ADF as an orchestrator.

I am quite confused how this will handle my data so please clarify if I misunderstood it.

First, I will run my ADF pipeline which includes an activity to call my AutoLoader notebook. Will it work like below or will it just process all the files in the folder once I run the ADF pipeline?

***I'm using option("includeExistingFiles", False) on my readStream

[szymon_dybczak · Accepted solution]

Auto loader will process files incrementally. Let's say you have a files in existing directory called /input_files

First time you run autoloader, it will read all files in that directory (unless you set an option includeExsistingFiles to false, like you did) and save information about what files has been read to checkpoint location. 

Next run will only load new files, because auto loader knows what has been loaded previously thanks to checkpoint

[zll_0091]

I see. So even though my stream stops it can still identify the files that was processed using the info in checkpoint location?

[szymon_dybczak]

Exactly, you got it right 😉

[Kaniz_Fatma]

Hi @zll_0091, Hi, Thank you for reaching out to our community! We're here to help you.

To ensure we provide you with the best support, could you please take a moment to review the response and choose the one that best answers your question? Your feedback not only helps us assist you better but also benefits other community members who may have similar questions in the future.

If you found the answer helpful, consider giving it a kudo. If the response fully addresses your question, please mark it as the accepted solution. This will help us close the thread and ensure your question is resolved.

We appreciate your participation and are here to assist you further if you need it!