We are using streaming connections, and the connection takes around 1.3 hours to run. During this duration, 2–3 batches get created.With _acp_system_metadata.acp_sourceBatchId, I tried this approach, but I am not sure what should be added in the WHERE condition to filter the data based on the Data ...