neilconway commented on code in PR #22679:
URL: https://github.com/apache/datafusion/pull/22679#discussion_r3333601273
##########
datafusion/physical-expr/src/projection.rs:
##########
@@ -2866,6 +2866,59 @@ pub(crate) mod tests {
Ok(())
}
+ #[test]
+ fn test_project_statistics_duplicate_column() -> Result<()> {
+ // SELECT col0 AS a, col0 AS b: both outputs carry col0's statistics.
+ let input_stats = get_stats();
+ let col0 = input_stats.column_statistics[0].clone();
+ let projection = ProjectionExprs::new([
+ ProjectionExpr::new(Arc::new(Column::new("col0", 0)), "a"),
+ ProjectionExpr::new(Arc::new(Column::new("col0", 0)), "b"),
+ ]);
+
+ let output_schema = projection.project_schema(&get_schema())?;
+ let output_stats = projection.project_statistics(input_stats,
&output_schema)?;
+
+ assert_eq!(output_stats.column_statistics, vec![col0.clone(), col0]);
+ Ok(())
+ }
+
+ #[test]
+ fn test_project_statistics_column_and_cast() -> Result<()> {
+ // SELECT col0 AS num, CAST(col0 AS Int32) AS casted: the passthrough
Review Comment:
Sure, removed.
--
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]
