Hi All, I have a query if someone can please help. Is there any metric or mechanism of printing count of input records dropped due to watermarking (late data count) in a stream, during a window based aggregation, in Structured Streaming ? I am using Spark 3.0.
Thanks & Regards, Rajat
