Scalable data pipeline design