(
&self,
exprs: Vec<Vec<SQLExpr>>,
schema: &DFSchema,
planner_context: &mut PlannerContext,
)
| 40 | } |
| 41 | |
| 42 | pub(super) fn sql_rollup_to_expr( |
| 43 | &self, |
| 44 | exprs: Vec<Vec<SQLExpr>>, |
| 45 | schema: &DFSchema, |
| 46 | planner_context: &mut PlannerContext, |
| 47 | ) -> Result<Expr> { |
| 48 | let args: Result<Vec<_>> = exprs |
| 49 | .into_iter() |
| 50 | .map(|v| { |
| 51 | if v.len() != 1 { |
| 52 | plan_err!( |
| 53 | "Tuple expressions are not supported for Rollup expressions" |
| 54 | ) |
| 55 | } else { |
| 56 | self.sql_expr_to_logical_expr(v[0].clone(), schema, planner_context) |
| 57 | } |
| 58 | }) |
| 59 | .collect(); |
| 60 | Ok(Expr::GroupingSet(GroupingSet::Rollup(args?))) |
| 61 | } |
| 62 | |
| 63 | pub(super) fn sql_cube_to_expr( |
| 64 | &self, |
no test coverage detected