Skip to content

Commit d3bb21f

Browse files
chore: some cleanup
1 parent edb2f67 commit d3bb21f

2 files changed

Lines changed: 13 additions & 11 deletions

File tree

‎datafusion/optimizer/src/decorrelate.rs‎

Lines changed: 5 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -77,11 +77,11 @@ pub struct PullUpCorrelatedExpr {
7777
pub pulled_up_scalar_agg: bool,
7878
/// A correlated column wrapped in an expression (e.g. `CAST(t2.b AS INT)`)
7979
/// gets grouped by that entire expression instead of the bare column,
80-
/// aliased to a generated name, once, in the `Aggregate` this column belongs to. Every
81-
/// later reference to that column, in a `Projection` above it for
82-
/// instance, needs to use the same alias instead of the now
83-
/// unresolvable bare column. This records the mapping the first
84-
/// time it's made.
80+
/// aliased to a generated name, once, in the `Aggregate` this column
81+
/// belongs to. Every later reference to that column, in a
82+
/// `Projection` above it for instance, needs to use the same alias
83+
/// instead of the now unresolvable bare column. This records the
84+
/// mapping the first time it's made.
8585
correlated_col_aliases: HashMap<Column, Expr>,
8686
/// `LIMIT 0` forces the subquery to zero rows unconditionally, regardless
8787
/// of whether the correlation matched, collapsing it to an `EmptyRelation`.

‎datafusion/optimizer/src/decorrelate_predicate_subquery.rs‎

Lines changed: 8 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -675,7 +675,7 @@ fn build_join_with_count_bug(
675675
) -> Result<LogicalPlan> {
676676
if in_predicate_opt.is_some() {
677677
return not_impl_err!(
678-
"build_join_with_count_bug: `IN`/`NOT IN` count-bug compensation is not implemented"
678+
"IN/NOT IN count-bug compensation for groupless aggregates is not implemented"
679679
);
680680
}
681681

@@ -719,12 +719,14 @@ fn build_join_with_count_bug(
719719
};
720720

721721
// EXISTS is true by default (the groupless aggregate always
722-
// produces a row), unless one of three cases holds: (1) the outer
723-
// row joined against an inner group whose HAVING predicate failed,
722+
// produces a row), unless one of three cases holds:
723+
// (1) the outer row joined against an inner group whose HAVING
724+
// predicate failed,
724725
// (2) an unmatched outer row's own default aggregate values fail
725-
// that same HAVING clause, or (3) the subquery was truncated to
726-
// zero rows unconditionally (LIMIT 0), which is false for every
727-
// outer row regardless of whether it matched.
726+
// that same HAVING clause,
727+
// (3) the subquery was truncated to zero rows unconditionally
728+
// (LIMIT 0), which is false for every outer row regardless of
729+
// whether it matched.
728730
let exists_expr = if forces_empty_result {
729731
lit(false)
730732
} else {

0 commit comments

Comments
 (0)