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

Method normalize

datafusion/expr/src/logical_plan/builder.rs:1001–1014  ·  view source on GitHub ↗
(plan: &LogicalPlan, column: Column)

Source from the content-addressed store, hash-verified

999 }
1000
1001 pub(crate) fn normalize(plan: &LogicalPlan, column: Column) -> Result<Column> {
1002 if column.relation.is_some() {
1003 // column is already normalized
1004 return Ok(column);
1005 }
1006
1007 let schema = plan.schema();
1008 let fallback_schemas = plan.fallback_normalize_schemas();
1009 let using_columns = plan.using_columns()?;
1010 column.normalize_with_schemas_and_ambiguity_check(
1011 &[&[schema], &fallback_schemas],
1012 &using_columns,
1013 )
1014 }
1015
1016 /// Apply a join with on constraint and specified null equality.
1017 ///

Callers

nothing calls this directly

Calls 4

using_columnsMethod · 0.80
schemaMethod · 0.45

Tested by

no test coverage detected