Hi Spark Dev, I have extended traditional DRA to work for structured streaming use-case.
Here is an initial Implementation draft PR https://github.com/apache/spark/pull/42352 and design doc: https://docs.google.com/document/d/1_YmfCsQQb9XhRdKh0ijbc-j8JKGtGBxYsk_30NVSTWo/edit?usp=sharing Please review and let me know what you think. Thank you, Pavan
