Skip to content

Commit

Permalink
Fixed SortMergeJoinTest
Browse files Browse the repository at this point in the history
  • Loading branch information
jacobfi committed Mar 21, 2024
1 parent b8a82f0 commit 1836889
Showing 1 changed file with 1 addition and 1 deletion.
Expand Up @@ -42,7 +42,7 @@ class SortMergeJoinTest extends AnyFunSuite:

test("Join on scala.Predef.String and java.lang.String"):
case class Score(name: String, points: Int)
val scores = Seq(Score("abc", 20), Score("def", 40)).map(Score.unapply).toDataFrame("name", "points")
val scores = Seq(Score("abc", 20), Score("def", 40)).map(s => (s.name, s.points)).toDataFrame("name", "points")
val names = Seq("abc", "def").toDataFrame("name")
val joined = scores.join(names, $"name")
assert(joined.rowCount == 2)

0 comments on commit 1836889

Please sign in to comment.