Skip to content

Commit 74e3422

Browse files
committed
Fix benchmarks: CastColumnExpr -> CastExpr::new_with_target_field
1 parent 42ac014 commit 74e3422

1 file changed

Lines changed: 2 additions & 3 deletions

File tree

benchmarks/src/datasets/tpcds.rs

Lines changed: 2 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -3,7 +3,7 @@ use arrow::datatypes::{DataType, Field};
33
use datafusion::common::internal_err;
44
use datafusion::error::DataFusionError;
55
use datafusion::physical_expr::Partitioning;
6-
use datafusion::physical_expr::expressions::{CastColumnExpr, Column};
6+
use datafusion::physical_expr::expressions::{CastExpr, Column};
77
use datafusion::physical_expr::projection::ProjectionExpr;
88
use datafusion::physical_plan::ExecutionPlan;
99
use datafusion::physical_plan::projection::ProjectionExec;
@@ -148,9 +148,8 @@ fn project_cols_as_dict(
148148
.enumerate()
149149
.map(|(i, f)| ProjectionExpr {
150150
expr: if cols.contains(&f.name().as_str()) {
151-
Arc::new(CastColumnExpr::new(
151+
Arc::new(CastExpr::new_with_target_field(
152152
Arc::new(Column::new(f.name(), i)),
153-
f.clone(),
154153
Arc::new(Field::new(
155154
f.name(),
156155
DataType::Dictionary(

0 commit comments

Comments
 (0)