I am using Spark Structured Streaming to aggregate data. I’m facing an issue with newly updated data. Suppose I have a dataframe with 3 columns and I previously aggregated the data to get 5 records. When there is new data which is an update to an existing record, how can I aggregate based on the updated data?

Hope everyone can help me solve the above problem.