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

Reply via email to