Given a use case where you need to implement a common design pattern using Structured Streaming and Delta Lake, describe how you would set up a streaming query to handle late-arriving data and ensure data consistency. Include the use of watermarking and the merge operation in your answer.