alamb commented on code in PR #8006:
URL: https://github.com/apache/arrow-datafusion/pull/8006#discussion_r1380559285
##########
datafusion/physical-plan/src/projection.rs:
##########
@@ -60,15 +56,12 @@ pub struct ProjectionExec {
input: Arc<dyn ExecutionPlan>,
/// The output ordering
output_ordering: Option<Vec<PhysicalSortExpr>>,
- /// The columns map used to normalize out expressions like Partitioning
and PhysicalSortExpr
- /// The key is the column from the input schema and the values are the
columns from the output schema
- columns_map: HashMap<Column, Vec<Column>>,
+ /// The mapping used to normalize expressions like Partitioning and
+ /// PhysicalSortExpr. The key is the expression from the input schema
+ /// and the value is the expression from the output schema.
+ projection_mapping: Vec<(Arc<dyn PhysicalExpr>, Arc<dyn PhysicalExpr>)>,
Review Comment:
BTW I made a PR to do this here --
https://github.com/apache/arrow-datafusion/pull/8033 and it worked out well.
Once this PR is merged I'll rebase it and get it ready for review
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
