@Alberto_Umana Thank you for the quick reply. But how are we to use the above, this looks like structured streaming with CDF mode.

But currently our tables being in Unity catalog, finding the start version and end version is taking huge time as the tables are near real time data. So, we wanted to read the source using DLT instead of CDF mode. So, reading the source with DLT, how should we use the above option of ForEachBatch and Merge? Could you please guide?