Hi Team, Hope you all are doing well. I have run into a use case in which I want to do the aggregation in foreachbatch and use update mode for handling late data in structured streaming. Will this approach work in effectively capturing late arriving data in the aggregations? Please help.
Thanking you, Om Prakash