At Sociallytix Corp , you are building a system to ingest and analyze social media posts using Google BigQuery , processing around 10,000 messages per minute in near real-time. Your initial design uses streaming inserts to load each post into BigQuery. After each insert, your application runs aggregation queries on the new data. However, you notice that the queries sometimes return incomplete results due to eventual consistency of streaming inserts, causing in-flight data to be missed in reports. How should you modify your application design to address this issue?