From ed6b171edebcd62388d1bbea192012d276b71bbf Mon Sep 17 00:00:00 2001 From: "wangguangxin.cn" Date: Wed, 5 Jun 2024 15:43:41 +0800 Subject: [PATCH] add more ut --- .../org/apache/gluten/execution/TestOperator.scala | 10 ++++++++++ 1 file changed, 10 insertions(+) diff --git a/backends-velox/src/test/scala/org/apache/gluten/execution/TestOperator.scala b/backends-velox/src/test/scala/org/apache/gluten/execution/TestOperator.scala index b0b67e94d501b..469010832f6c5 100644 --- a/backends-velox/src/test/scala/org/apache/gluten/execution/TestOperator.scala +++ b/backends-velox/src/test/scala/org/apache/gluten/execution/TestOperator.scala @@ -210,6 +210,16 @@ class TestOperator extends VeloxWholeStageTransformerSuite { Seq("sort", "streaming").foreach { windowType => withSQLConf("spark.gluten.sql.columnar.backend.velox.window.type" -> windowType) { + runQueryAndCompare( + "select max(l_partkey) over" + + " (partition by l_suppkey order by l_orderkey" + + " RANGE BETWEEN 1 PRECEDING AND CURRENT ROW), " + + "min(l_comment) over" + + " (partition by l_suppkey order by l_discount" + + " RANGE BETWEEN 1 PRECEDING AND CURRENT ROW) from lineitem ") { + checkSparkOperatorMatch[WindowExecTransformer] + } + runQueryAndCompare( "select max(l_partkey) over" + " (partition by l_suppkey order by l_orderkey" +