You are developing a data pipeline for a retail company that needs to analyze customer purchase patterns in real-time. The pipeline processes data from multiple sources, including online transactions, in-store purchases, and customer feedback. How would you optimize the pipeline for analytical purposes?