Skip to content

Commit

Permalink
merge
Browse files Browse the repository at this point in the history
  • Loading branch information
comphead committed Mar 19, 2024
1 parent a44c060 commit 2a652fa
Showing 1 changed file with 3 additions and 3 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -1146,11 +1146,11 @@ class CometExecSuite extends CometTestBase {
println("df: " + df1.collectAsList())
checkAnswer(df1, Seq(Row(null, 2, 1), Row(null, 4, 2), Row(null, 6, 3)))

// val bosonWindowExec = stripAQEPlan(df1.queryExecution.executedPlan).collect {
// case b: BosonWindowExec => b
// val cometWindowExec = stripAQEPlan(df1.queryExecution.executedPlan).collect {
// case b: CometWindowExec => b
// }
//
// assert(bosonWindowExec.length == 1)
// assert(cometWindowExec.length == 1)
//
// val df2 = spark.sql("""
// |SELECT b, RANK() OVER(ORDER BY a, b) AS rk, DENSE_RANK(b) OVER(ORDER BY a, b) AS s
Expand Down

0 comments on commit 2a652fa

Please sign in to comment.