Skip to content

Commit

Permalink
Update tests 3
Browse files Browse the repository at this point in the history
  • Loading branch information
Dandandan committed Sep 28, 2023
1 parent f189d9a commit b283946
Show file tree
Hide file tree
Showing 2 changed files with 3 additions and 5 deletions.
6 changes: 2 additions & 4 deletions datafusion/optimizer/src/push_down_filter.rs
Original file line number Diff line number Diff line change
Expand Up @@ -1056,7 +1056,6 @@ mod tests {
// filter is before projection
let expected = "\
Projection: test.a AS b, test.c\
\n Filter: test.a = Int64(1)\
\n TableScan: test, full_filters=[test.a = Int64(1)]";
assert_optimized_plan_eq(&plan, expected)
}
Expand Down Expand Up @@ -1281,8 +1280,7 @@ mod tests {
Filter: SUM(test.c) > Int64(10)\
\n Aggregate: groupBy=[[b]], aggr=[[SUM(test.c)]]\
\n Projection: test.a AS b, test.c\
\n Filter: test.a > Int64(10)\
\n TableScan: test";
\n TableScan: test, full_filters=[test.a > Int64(10)]";
assert_optimized_plan_eq(&plan, expected)
}

Expand Down Expand Up @@ -2664,7 +2662,7 @@ Projection: a, b
\n Projection: test1.a, test1.b\
\n TableScan: test1\
\n Projection: test2.a, test2.b\
\n TableScan: test2, full_filters=[test2.b > UInt32(2)] ";
\n TableScan: test2, full_filters=[test2.b > UInt32(2)]";
assert_optimized_plan_eq(&plan, expected)
}

Expand Down
2 changes: 1 addition & 1 deletion datafusion/optimizer/src/push_down_projection.rs
Original file line number Diff line number Diff line change
Expand Up @@ -981,7 +981,7 @@ mod tests {
let table_scan = table_scan_with_filters(
Some("test"),
&schema,
Some(vec![2]),
None,
vec![col("b").eq(lit(1))],
)?
.build()?;
Expand Down

0 comments on commit b283946

Please sign in to comment.