Skip to content

Commit

Permalink
Code style
Browse files Browse the repository at this point in the history
Signed-off-by: Andy Kwok <[email protected]>
  • Loading branch information
andy-k-improving committed Dec 16, 2024
1 parent 6269b5b commit 2847e5a
Showing 1 changed file with 11 additions and 5 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -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"""
Expand Down Expand Up @@ -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)),
Expand Down

0 comments on commit 2847e5a

Please sign in to comment.