Skip to content

Commit 554abaf

Browse files
committed
feat: do not fallback to Spark for distincts
1 parent 4177f63 commit 554abaf

File tree

1 file changed

+12
-0
lines changed

1 file changed

+12
-0
lines changed

spark/src/test/scala/org/apache/comet/CometFuzzAggregateSuite.scala

Lines changed: 12 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -45,6 +45,18 @@ class CometFuzzAggregateSuite extends CometFuzzTestBase {
4545
}
4646
}
4747

48+
test("count distinct multiple values and group by multiple column") {
49+
val df = spark.read.parquet(filename)
50+
df.createOrReplaceTempView("t1")
51+
for (col <- df.columns) {
52+
val sql = s"SELECT c1, c2, c3, count(distinct $col, c4, c5) FROM t1 group by c1, c2, c3"
53+
val (_, cometPlan) = checkSparkAnswer(sql)
54+
if (usingDataSourceExec) {
55+
assert(1 == collectNativeScans(cometPlan).length)
56+
}
57+
}
58+
}
59+
4860
test("count(*) group by single column") {
4961
val df = spark.read.parquet(filename)
5062
df.createOrReplaceTempView("t1")

0 commit comments

Comments
 (0)