You are in the process of developing a real-time data warehouse for your company using Google BigQuery streaming inserts. Given the nature of the data stream, there isn't a guarantee that the data will be sent only once. However, each row of data does include a unique ID and an event timestamp. To ensure that duplicates are excluded during interactive query sessions, which type of query should you implement?