From 2847e5a9161be72b2f9dc4951136c05a31bee7d2 Mon Sep 17 00:00:00 2001 From: Andy Kwok Date: Mon, 16 Dec 2024 14:50:19 -0800 Subject: [PATCH] Code style Signed-off-by: Andy Kwok --- .../ppl/FlintSparkPPLAppendColITSuite.scala | 16 +++++++++++----- 1 file changed, 11 insertions(+), 5 deletions(-) diff --git a/integ-test/src/integration/scala/org/opensearch/flint/spark/ppl/FlintSparkPPLAppendColITSuite.scala b/integ-test/src/integration/scala/org/opensearch/flint/spark/ppl/FlintSparkPPLAppendColITSuite.scala index 418dbc81c..0cb98c0e9 100644 --- a/integ-test/src/integration/scala/org/opensearch/flint/spark/ppl/FlintSparkPPLAppendColITSuite.scala +++ b/integ-test/src/integration/scala/org/opensearch/flint/spark/ppl/FlintSparkPPLAppendColITSuite.scala @@ -343,7 +343,8 @@ class FlintSparkPPLAppendColITSuite } /** - * To simulate the use-case when column `age` present on both main and sub search, with option OVERRIDE=true. + * To simulate the use-case when column `age` present on both main and sub search, with option + * OVERRIDE=true. */ test("test AppendCol with OVERRIDE option") { val frame = sql(s""" @@ -392,11 +393,16 @@ class FlintSparkPPLAppendColITSuite "T2", Project( Seq(ROW_NUMBER_AGGREGATION, UnresolvedStar(None)), - Aggregate(Nil, Seq(Alias( - UnresolvedFunction(Seq("COUNT"), Seq(UnresolvedStar(None)), isDistinct = false), - "age")()), RELATION_TEST_TABLE))) + Aggregate( + Nil, + Seq( + Alias( + UnresolvedFunction(Seq("COUNT"), Seq(UnresolvedStar(None)), isDistinct = false), + "age")()), + RELATION_TEST_TABLE))) - val overrideFields = Seq(UnresolvedAttribute("T1._row_number_"), UnresolvedAttribute("T1.age")) + val overrideFields = + Seq(UnresolvedAttribute("T1._row_number_"), UnresolvedAttribute("T1.age")) val expectedPlan = Project( Seq(UnresolvedStar(None)),