test_in.scala

test("in") {
 # main = createDataDataset(Seq(Data("a", "Berlin"), Data("b", "Madrid"), Data("c", "Rome")))
 # dict = createDictDataset(Seq(Dict("a"), Dict("b")))
 val result = main.join(dict, Seq("index"), "left_semi")
 val expected = createDataDataset(Seq(
   Data("a", "Berlin"), Data("b", "Madrid"))).orderBy("index")

 assert(result.schema === expected.schema)
 assert(result.collect() === expected.toDF().collect())
}