(
operator: Operator,
predicate: &'a Arc<dyn PhysicalExpr>,
mut exprs: Vec<&'a Arc<dyn PhysicalExpr>>,
)
| 140 | } |
| 141 | |
| 142 | fn split_impl<'a>( |
| 143 | operator: Operator, |
| 144 | predicate: &'a Arc<dyn PhysicalExpr>, |
| 145 | mut exprs: Vec<&'a Arc<dyn PhysicalExpr>>, |
| 146 | ) -> Vec<&'a Arc<dyn PhysicalExpr>> { |
| 147 | match predicate.downcast_ref::<BinaryExpr>() { |
| 148 | Some(binary) if binary.op() == &operator => { |
| 149 | let exprs = split_impl(operator, binary.left(), exprs); |
| 150 | split_impl(operator, binary.right(), exprs) |
| 151 | } |
| 152 | Some(_) | None => { |
| 153 | exprs.push(predicate); |
| 154 | exprs |
| 155 | } |
| 156 | } |
| 157 | } |
| 158 | |
| 159 | /// This function maps back requirement after ProjectionExec |
| 160 | /// to the Executor for its input. |
no test coverage detected
searching dependent graphs…