MCPcopy Create free account
hub / github.com/apache/datafusion / count_expr

Method count_expr

datafusion/core/tests/physical_optimizer/test_utils.rs:663–669  ·  view source on GitHub ↗

Return appropriate expr depending if COUNT is for col or table (*)

(&self, schema: &Schema)

Source from the content-addressed store, hash-verified

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> {

Callers

nothing calls this directly

Calls 6

newFunction · 0.85
column_nameMethod · 0.80
buildMethod · 0.45
aliasMethod · 0.45
schemaMethod · 0.45
cloneMethod · 0.45

Tested by

no test coverage detected