Return appropriate expr depending if COUNT is for col or table (*)
(&self, schema: &Schema)
| 661 | |
| 662 | /// Return appropriate expr depending if COUNT is for col or table (*) |
| 663 | pub fn count_expr(&self, schema: &Schema) -> AggregateFunctionExpr { |
| 664 | AggregateExprBuilder::new(count_udaf(), vec![self.column()]) |
| 665 | .schema(Arc::new(schema.clone())) |
| 666 | .alias(self.column_name()) |
| 667 | .build() |
| 668 | .unwrap() |
| 669 | } |
| 670 | |
| 671 | /// what argument would this aggregate need in the plan? |
| 672 | fn column(&self) -> Arc<dyn PhysicalExpr> { |