How would you design a data pipeline to handle late-arriving data in an incremental loading scenario?
