Skip to content

Commit d61280a

Browse files
committed
Review comments
1 parent c45a6c8 commit d61280a

2 files changed

Lines changed: 11 additions & 5 deletions

File tree

datafusion/src/execution/context.rs

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -3379,7 +3379,7 @@ mod tests {
33793379

33803380
fn create_physical_expr(
33813381
&self,
3382-
_e: &Expr,
3382+
_expr: &Expr,
33833383
_input_dfschema: &crate::logical_plan::DFSchema,
33843384
_input_schema: &Schema,
33853385
_ctx_state: &ExecutionContextState,

datafusion/src/physical_plan/planner.rs

Lines changed: 10 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -183,14 +183,14 @@ pub trait PhysicalPlanner {
183183
/// Create a physical expression from a logical expression
184184
/// suitable for evaluation
185185
///
186-
/// `e`: the expression to convert
186+
/// `expr`: the expression to convert
187187
///
188188
/// `input_dfschema`: the logical plan schema for evaluating `e`
189189
///
190190
/// `input_schema`: the physical schema for evaluating `e`
191191
fn create_physical_expr(
192192
&self,
193-
e: &Expr,
193+
expr: &Expr,
194194
input_dfschema: &DFSchema,
195195
input_schema: &Schema,
196196
ctx_state: &ExecutionContextState,
@@ -254,12 +254,18 @@ impl PhysicalPlanner for DefaultPhysicalPlanner {
254254
/// `input_schema`: the physical schema for evaluating `e`
255255
fn create_physical_expr(
256256
&self,
257-
e: &Expr,
257+
expr: &Expr,
258258
input_dfschema: &DFSchema,
259259
input_schema: &Schema,
260260
ctx_state: &ExecutionContextState,
261261
) -> Result<Arc<dyn PhysicalExpr>> {
262-
self.create_physical_expr(e, input_dfschema, input_schema, ctx_state)
262+
DefaultPhysicalPlanner::create_physical_expr(
263+
self,
264+
expr,
265+
input_dfschema,
266+
input_schema,
267+
ctx_state,
268+
)
263269
}
264270
}
265271

0 commit comments

Comments
 (0)