add HAVING filter
@@ -410,6 +410,7 @@ mod tests {
let plan = PlanBuilder::from(&source_plan)
.limit(10)?
.sort(&vec![col("e")])?
+ .filter(col("d").lt(lit(10)))?
.aggregate_partial(vec![], group_exprs)?
.filter(col("b").eq(lit(10)))?
.project(vec![col("a")])?
@@ -422,9 +423,10 @@ mod tests {
Projection: a:Utf8\
\n Filter: (b = 10)\
\n AggregatorPartial: groupBy=[[a, c]], aggr=[[]]\
+ \n Filter: (d < 10)\
\n Sort: e:Utf8\
\n Limit: 10\
- \n ReadDataSource: scan partitions: [8], scan schema: [a:Utf8, b:Utf8, c:Utf8], statistics: [read_rows: 10000, read_bytes: 80000]";
+ \n ReadDataSource: scan partitions: [8], scan schema: [a:Utf8, b:Utf8, c:Utf8, d:Utf8], statistics: [read_rows: 10000, read_bytes: 80000]";
let actual = format!("{:?}", optimized);
assert_eq!(expect, actual);
