pub fn has_batch_exchange_where<P>(plan: PlanRef, pred: P) -> boolwhere P: FnMut(&BatchExchange) -> bool,