LLDay commented on code in PR #20009:
URL: https://github.com/apache/datafusion/pull/20009#discussion_r2754002839
##########
datafusion/physical-plan/src/joins/symmetric_hash_join.rs:
##########
@@ -647,6 +650,97 @@ impl ExecutionPlan for SymmetricHashJoinExec {
)
.map(|e| Some(Arc::new(e) as _))
}
+
+ fn physical_expressions<'a>(
+ &'a self,
+ ) -> Option<Box<dyn Iterator<Item = Arc<dyn PhysicalExpr>> + 'a>> {
+ let left_sort_iter = self
Review Comment:
Resolved plan:
```
ProjectionExec: expr=[name@1 as name, age@0 as age]
HashJoinExec: mode=CollectLeft, join_type=Inner, on=[(id@0, t1.id +
$1@2)], projection=[age@1, name@3]
DataSourceExec: partitions=1, partition_sizes=[1]
ProjectionExec: expr=[id@0 as id, name@1 as name, id@0 + 8 as t1.id + $1]
DataSourceExec: partitions=1, partition_sizes=[1]
```
`on` contains a list of columns. The first column is the `id`, the second
column has the name `t1.id + $1`. We can see that `ProjectionExec` returns the
third column `id + 8` with the alias `t1.id + $1`.
--
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]
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
