我尝试在一个名为 test . 以下代码与单列一起用于执行搜索：

val dfMongo = MongoSpark.load(sparkSession, confMongoDb.getReadConfig("test"))

然后，构建一个数组以选择相应的 ID 价值观：

val colToComp = dfUsedForSearch
  .select("ID")
  .map(r =>{r.getString(0)})
  .collect()

最后，搜索 ID 在mongodb集合中执行以下操作：

val dfFilter = dfMongo.filter(dfMongo.col("ID").isInCollection(colToComp))
  .select("ID")

如何使用复合键进行此类搜索，例如： (ID_A, ID_B, ID_C) ?