From b87ae4df5c64febebea132c5c13aaa71751bc7eb Mon Sep 17 00:00:00 2001 From: yangchuan Date: Mon, 30 Oct 2023 10:19:26 +0800 Subject: [PATCH] fix format --- .../VeloxAggregateFunctionsSuite.scala | 62 +++++++++---------- 1 file changed, 30 insertions(+), 32 deletions(-) diff --git a/backends-velox/src/test/scala/io/glutenproject/execution/VeloxAggregateFunctionsSuite.scala b/backends-velox/src/test/scala/io/glutenproject/execution/VeloxAggregateFunctionsSuite.scala index 8263d79db9210..ec7f3337e251b 100644 --- a/backends-velox/src/test/scala/io/glutenproject/execution/VeloxAggregateFunctionsSuite.scala +++ b/backends-velox/src/test/scala/io/glutenproject/execution/VeloxAggregateFunctionsSuite.scala @@ -420,46 +420,44 @@ class VeloxAggregateFunctionsSuite extends VeloxWholeStageTransformerSuite { } test("max_by") { - runQueryAndCompare( - s""" - |select max_by(l_linenumber, l_comment) from lineitem; - |""".stripMargin) { + runQueryAndCompare(s""" + |select max_by(l_linenumber, l_comment) from lineitem; + |""".stripMargin) { checkOperatorMatch[HashAggregateExecTransformer] } - runQueryAndCompare( - s""" - |select max_by(distinct l_linenumber, l_comment) - |from lineitem - |""".stripMargin) { - df => { - assert( - getExecutedPlan(df).count( - plan => { - plan.isInstanceOf[HashAggregateExecTransformer] - }) == 4) - } + runQueryAndCompare(s""" + |select max_by(distinct l_linenumber, l_comment) + |from lineitem + |""".stripMargin) { + df => + { + assert( + getExecutedPlan(df).count( + plan => { + plan.isInstanceOf[HashAggregateExecTransformer] + }) == 4) + } } } test("min_by") { - runQueryAndCompare( - s""" - |select min_by(l_linenumber, l_comment) from lineitem; - |""".stripMargin) { + runQueryAndCompare(s""" + |select min_by(l_linenumber, l_comment) from lineitem; + |""".stripMargin) { checkOperatorMatch[HashAggregateExecTransformer] } - runQueryAndCompare( - s""" - |select min_by(distinct l_linenumber, l_comment) - |from lineitem - |""".stripMargin) { - df => { - assert( - getExecutedPlan(df).count( - plan => { - plan.isInstanceOf[HashAggregateExecTransformer] - }) == 4) - } + runQueryAndCompare(s""" + |select min_by(distinct l_linenumber, l_comment) + |from lineitem + |""".stripMargin) { + df => + { + assert( + getExecutedPlan(df).count( + plan => { + plan.isInstanceOf[HashAggregateExecTransformer] + }) == 4) + } } }