我正在使用elastic4s库查询elasticsearch(ES)。 elastic4s和ES本身的版本2.4.0。
假设我有一个类似ES的复合对象
case class MyObject(id: Long, vall: KeyVal, vals: Seq[KeyVal])
KeyVal在哪里
case class KeyVal(id: Long, name: String)
现在,我查询ES并得到想要反序列化回
MyObject
的响应:implicit object MyObjectHitAs extends HitAs[MyObject] {
override def as(hit: RichSearchHit): MyObject = {
MyObject(
hit.field("id").getValue[String]
KeyVal(hit.field("vall.id").getValue[Long], field("vall.name").getValue[String]),
//what should I code here to get the Seq[KeyVal] ???
)
}
}
请说明如何反序列化KeyVal数组。谢谢。
最佳答案
在elastic4s的较新版本(即5.0及更高版本)中,应使用HitReader
类型类。您的示例将如下所示。
implicit object MyObjectHitAs extends HitReader[MyObject] {
override def read(hit: Hit): Either[Throwable, MyObject] = {
val obj = MyObject(
hit.sourceField("id").toString.toLong,
KeyVal(hit.sourceField("vall.id").toString.toLong, hit.sourceField("vall.name").toString),
hit.sourceField("vals").asInstanceOf[Seq[AnyRef]].map { entry =>
KeyVal(hit.sourceField("vall.id").toString.toLong, hit.sourceField("vall.name").toString)
}
)
Right(obj)
}
}
尽管使用built in json mappers比手工制作要容易得多。
关于scala - elastic4s:反序列化搜索结果,我们在Stack Overflow上找到一个类似的问题:https://stackoverflow.com/questions/40517893/