Constructs a join operator from inputs and required-equal scalar expressions.
(
mut inputs: Vec<MirRelationExpr>,
equivalences: Vec<Vec<MirScalarExpr>>,
)
| 1306 | |
| 1307 | /// Constructs a join operator from inputs and required-equal scalar expressions. |
| 1308 | pub fn join_scalars( |
| 1309 | mut inputs: Vec<MirRelationExpr>, |
| 1310 | equivalences: Vec<Vec<MirScalarExpr>>, |
| 1311 | ) -> Self { |
| 1312 | // Remove all constant inputs that are the identity for join. |
| 1313 | // They neither introduce nor modify any column references. |
| 1314 | inputs.retain(|i| !i.is_constant_singleton()); |
| 1315 | MirRelationExpr::Join { |
| 1316 | inputs, |
| 1317 | equivalences, |
| 1318 | implementation: JoinImplementation::Unimplemented, |
| 1319 | } |
| 1320 | } |
| 1321 | |
| 1322 | /// Perform a key-wise reduction / aggregation. |
| 1323 | /// |
nothing calls this directly
no test coverage detected