rust/greptimedb
1
0
Fork 0
mirror of https://github.com/GreptimeTeam/greptimedb.git synced 2026-01-03 20:02:54 +00:00
Code Issues Packages Projects Releases Wiki Activity

fix: update column requirements to use Column type instead of String (#5672)

Browse Source 
Signed-off-by: Ruihang Xia <waynestxia@gmail.com>
This commit is contained in:
Ruihang Xia
2025-03-07 10:50:15 -08:00
committed by GitHub
parent c8db4b286d
commit 373bd59b07
1 changed files with 7 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files

12
src/query/src/dist_plan/analyzer.rs
View File

@@ -153,7 +153,7 @@ struct PlanRewriter {
status: RewriterStatus,
/// Partition columns of the table in current pass
partition_cols: Option<Vec<String>>,
column_requirements: HashSet<String>,
column_requirements: HashSet<Column>,
}
impl PlanRewriter {
@@ -216,7 +216,7 @@ impl PlanRewriter {
}
for col in container {
self.column_requirements.insert(col.quoted_flat_name());
self.column_requirements.insert(col);
}
}
@@ -306,7 +306,7 @@ impl PlanRewriter {
/// - Enforce column requirements for `LogicalPlan::Projection` nodes. Makes sure the
/// required columns are available in the sub plan.
struct EnforceDistRequirementRewriter {
column_requirements: HashSet<String>,
column_requirements: HashSet<Column>,
}
impl TreeNodeRewriter for EnforceDistRequirementRewriter {
@@ -320,7 +320,9 @@ impl TreeNodeRewriter for EnforceDistRequirementRewriter {
}
for expr in &projection.expr {
column_requirements.remove(&expr.name_for_alias()?);
let (qualifier, name) = expr.qualified_name();
let column = Column::new(qualifier, name);
column_requirements.remove(&column);
}
if column_requirements.is_empty() {
return Ok(Transformed::no(node));
@@ -328,7 +330,7 @@ impl TreeNodeRewriter for EnforceDistRequirementRewriter {
let mut new_exprs = projection.expr.clone();
for col in &column_requirements {
new_exprs.push(col_fn(col));
new_exprs.push(Expr::Column(col.clone()));
}
let new_node =
node.with_new_exprs(new_exprs, node.inputs().into_iter().cloned().collect())?;