Function collect_scanned_relation_ids 

fn collect_scanned_relation_ids(plan: StreamPlanRef) -> HashSet<ObjectId>

Collect all relation IDs (tables and sources) that are scanned in the plan.