Skip to content

Commit 11e69c5

Browse files
committed
tmp
1 parent 4337da9 commit 11e69c5

File tree

2 files changed

+6
-2
lines changed

2 files changed

+6
-2
lines changed

datafusion/core/src/logical_plan/expr_visitor.rs

Lines changed: 5 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -101,8 +101,11 @@ impl ExprVisitable for Expr {
101101
| Expr::Negative(expr)
102102
| Expr::Cast { expr, .. }
103103
| Expr::TryCast { expr, .. }
104-
| Expr::Sort { expr, .. }
105-
| Expr::GetIndexedField { expr, .. } => expr.accept(visitor),
104+
| Expr::Sort { expr, .. } => expr.accept(visitor),
105+
Expr::GetIndexedField { expr, key } => {
106+
let visitor = expr.accept(visitor)?;
107+
key.accept(visitor)
108+
}
106109
Expr::Column(_)
107110
| Expr::OuterColumn(_, _)
108111
| Expr::ScalarVariable(_, _)

datafusion/core/src/physical_plan/planner.rs

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -156,6 +156,7 @@ fn create_physical_name(e: &Expr, is_first_expr: bool) -> Result<String> {
156156
}
157157
Expr::GetIndexedField { expr, key } => {
158158
let expr = create_physical_name(expr, false)?;
159+
let key = create_physical_name(key, false)?;
159160
Ok(format!("{}[{}]", expr, key))
160161
}
161162
Expr::ScalarFunction { fun, args, .. } => {

0 commit comments

Comments
 (0)