You are responsible for designing a data pipeline that needs to handle data from a source system that has a high rate of data change. Which of the following strategies would you use to ensure efficient and timely processing of the data in Azure Data Factory?