You are responsible for optimizing the performance of a web application that processes large volumes of data. The application utilizes Google Cloud services such as BigQuery, Dataflow, and Pub/Sub. Which of the following strategies would be most effective in improving the performance of your data processing pipeline while minimizing costs?