Skip to content

Commit 5525659

Browse files
committed
fix after rebase
1 parent 8b6f25c commit 5525659

2 files changed

Lines changed: 13 additions & 1 deletion

File tree

native/core/src/execution/planner.rs

Lines changed: 6 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -4566,6 +4566,8 @@ mod tests {
45664566
type_info: None,
45674567
}),
45684568
})),
4569+
expr_id: None,
4570+
query_context: None,
45694571
};
45704572

45714573
// Create bound reference for the INT8 column (index 1)
@@ -4577,6 +4579,8 @@ mod tests {
45774579
type_info: None,
45784580
}),
45794581
})),
4582+
expr_id: None,
4583+
query_context: None,
45804584
};
45814585

45824586
// Create a Subtract expression: date_col - int8_col
@@ -4592,6 +4596,8 @@ mod tests {
45924596
}),
45934597
eval_mode: 0, // Legacy mode
45944598
}))),
4599+
expr_id: None,
4600+
query_context: None,
45954601
};
45964602

45974603
// Create a projection operator with the subtract expression

native/core/src/parquet/schema_adapter.rs

Lines changed: 7 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -349,7 +349,13 @@ impl SparkPhysicalExprAdapter {
349349
cast_options.allow_cast_unsigned_ints = self.parquet_options.allow_cast_unsigned_ints;
350350
cast_options.is_adapting_schema = true;
351351

352-
let spark_cast = Arc::new(Cast::new(child, target_type.clone(), cast_options));
352+
let spark_cast = Arc::new(Cast::new(
353+
child,
354+
target_type.clone(),
355+
cast_options,
356+
None,
357+
None,
358+
));
353359

354360
return Ok(Transformed::yes(spark_cast as Arc<dyn PhysicalExpr>));
355361
}

0 commit comments

Comments
 (0)