Hey , Thanks for suggestion . I too agree with you . I am just checking ,if we need to this in Databricks , then how we should approach this ?

I am comfortable in creating this pipeline in ADF using watermark column method, but i am not sure what's best approach in Databricks