What is the best way to handle late-arriving data in a streaming lakehouse?