Skip to content

Commit 0a0ef5c

Browse files
authored
chore: Fix link to issue and expand comment (#14473)
* Fix link to issue and expand comment The link to issue was incorrect. Also, expand the comment to indicate this is not the final desired state yet. * Fix variable name
1 parent c3dce97 commit 0a0ef5c

File tree

2 files changed

+8
-6
lines changed

2 files changed

+8
-6
lines changed

datafusion/expr/src/logical_plan/builder.rs

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -1906,8 +1906,8 @@ pub fn unnest_with_options(
19061906
.extend(std::iter::repeat(index).take(transformed_columns.len()));
19071907
Ok(transformed_columns
19081908
.iter()
1909-
.map(|(col, data_type)| {
1910-
(col.relation.to_owned(), data_type.to_owned())
1909+
.map(|(col, field)| {
1910+
(col.relation.to_owned(), field.to_owned())
19111911
})
19121912
.collect())
19131913
}

datafusion/optimizer/src/decorrelate.rs

Lines changed: 6 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -56,9 +56,10 @@ pub struct PullUpCorrelatedExpr {
5656
/// Indicates if we encounter any correlated expression that can not be pulled up
5757
/// above a aggregation without changing the meaning of the query.
5858
can_pull_over_aggregation: bool,
59-
/// Do we need to handle [the Count bug] during the pull up process
59+
/// Do we need to handle [the Count bug] during the pull up process.
60+
/// TODO this parameter should be removed or renamed semantically
6061
///
61-
/// [the Count bug]: https://github.com/apache/datafusion/pull/10500
62+
/// [the Count bug]: https://github.com/apache/datafusion/issues/10553
6263
pub need_handle_count_bug: bool,
6364
/// mapping from the plan to its expressions' evaluation result on empty batch
6465
pub collected_count_expr_map: HashMap<LogicalPlan, ExprResultMap>,
@@ -88,8 +89,9 @@ impl PullUpCorrelatedExpr {
8889
}
8990

9091
/// Set if we need to handle [the Count bug] during the pull up process
92+
/// TODO this should be removed or renamed semantically
9193
///
92-
/// [the Count bug]: https://github.com/apache/datafusion/pull/10500
94+
/// [the Count bug]: https://github.com/apache/datafusion/issues/10553
9395
pub fn with_need_handle_count_bug(mut self, need_handle_count_bug: bool) -> Self {
9496
self.need_handle_count_bug = need_handle_count_bug;
9597
self
@@ -111,7 +113,7 @@ impl PullUpCorrelatedExpr {
111113
/// Used to indicate the unmatched rows from the inner(subquery) table after the left out Join
112114
/// This is used to handle [the Count bug]
113115
///
114-
/// [the Count bug]: https://github.com/apache/datafusion/pull/10500
116+
/// [the Count bug]: https://github.com/apache/datafusion/issues/10553
115117
pub const UN_MATCHED_ROW_INDICATOR: &str = "__always_true";
116118

117119
/// Mapping from expr display name to its evaluation result on empty record

0 commit comments

Comments
 (0)