???
val result: DataFrame = searchTerms.flatMap { row =>
val searchTerm = row.getAs[String]("search_term")
spark.esDF(
resource = config.elasticSearch.inputIndexName,
query = esQuery(searchTerm, date),
cfg = config.elasticSearch.connection.readConfig()
)
}
немного не так работает
Да я уже понял что тут flatMap не православный
Обсуждают сегодня