agile-lab-dev / agile-lab-dev/sparksearchengine
Searching inside a map function is impossible?
Abierto
- Lenguaje dominante
- Scala
- Estrellas
- 18
- Forks
- 1
- Métricas de merge de PR
- Sin PR fusionados en 30 d
Descripción
```
val searchable: SearchableRDD[doc] = BroadcastIndexLuceneRDD(docRdd, luceneConfig).cache()
todoDF.map(row => {
val queryString = row.getAs[String]("the_query_string")
val query = "text" parseQuery queryString
val queryResults = searchable.aggregatingSearch(query, 10)
println(s"Results for query $query:")
queryResults foreach { result: (doc, Double) => println(f"\tscore: ${result._2}%6.3f title: ${result._1.text}") }
(1)
}).toDF("tmp").show()
```
@matteobovetti Thank you!
Guía de contribución
No hay ninguna guía de contribución indexada para este repositorio
Evaluación
Este issue todavía no se ha evaluado.