Hi @IsmaelHenzel1,

How are you doing today?

As per understanding, Consider using Delta Live Tables (DLT) materialized views to handle complex streaming logic as DLT doesn’t currently support foreachBatch. For windowing with lag, DLT materialized views can help, but without a direct time range in streaming, you may need to adjust your approach. If you create a materialized view, it will process data incrementally, similar to foreachBatch, using the underlying change data feed (CDF). This means it should only compute on new data rather than recomputing the entire dataset, giving you incremental processing similar to the behavior in foreachBatch.

Please give a try and let me know for any queries.

Regards,

Brahma